public class TaskExecutorProcessSpec extends Object implements Serializable
A TaskExecutor's memory consists of the following components.
The relationships of TaskExecutor memory components are shown below.
┌ ─ ─ Total Process Memory ─ ─ ┐ ┌ ─ ─ Total Flink Memory ─ ─ ┐ │ ┌───────────────────────────┐ │ ││ Framework Heap Memory ││ ─┐ │ └───────────────────────────┘ │ │ │ ┌───────────────────────────┐ │ │ ┌─ ││ Framework Off-Heap Memory ││ ├─ On-Heap │ │ └───────────────────────────┘ │ │ │ │┌───────────────────────────┐│ │ │ │ │ Task Heap Memory │ │ ─┘ │ │└───────────────────────────┘│ │ │ ┌───────────────────────────┐ │ ├─ ││ Task Off-Heap Memory ││ │ │ └───────────────────────────┘ │ │ │┌───────────────────────────┐│ ├─ │ │ Network Memory │ │ │ │└───────────────────────────┘│ │ │ ┌───────────────────────────┐ │ Off-Heap ─┼─ │ Managed Memory │ │ ││└───────────────────────────┘││ │ └ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┘ │ │┌─────────────────────────────┐│ ├─ │ JVM Metaspace │ │ │└─────────────────────────────┘│ │ ┌─────────────────────────────┐ └─ ││ JVM Overhead ││ └─────────────────────────────┘ └ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┘
Constructor and Description |
---|
TaskExecutorProcessSpec(CPUResource cpuCores,
MemorySize frameworkHeapSize,
MemorySize frameworkOffHeapSize,
MemorySize taskHeapSize,
MemorySize taskOffHeapSize,
MemorySize networkMemSize,
MemorySize managedMemorySize,
MemorySize jvmMetaspaceSize,
MemorySize jvmOverheadSize) |
Modifier and Type | Method and Description |
---|---|
CPUResource |
getCpuCores() |
MemorySize |
getFrameworkHeapSize() |
MemorySize |
getFrameworkOffHeapMemorySize() |
MemorySize |
getJvmDirectMemorySize() |
MemorySize |
getJvmHeapMemorySize() |
MemorySize |
getJvmMetaspaceSize() |
MemorySize |
getJvmOverheadSize() |
MemorySize |
getManagedMemorySize() |
MemorySize |
getNetworkMemSize() |
MemorySize |
getTaskHeapSize() |
MemorySize |
getTaskOffHeapSize() |
MemorySize |
getTotalFlinkMemorySize() |
MemorySize |
getTotalProcessMemorySize() |
String |
toString() |
public TaskExecutorProcessSpec(CPUResource cpuCores, MemorySize frameworkHeapSize, MemorySize frameworkOffHeapSize, MemorySize taskHeapSize, MemorySize taskOffHeapSize, MemorySize networkMemSize, MemorySize managedMemorySize, MemorySize jvmMetaspaceSize, MemorySize jvmOverheadSize)
public CPUResource getCpuCores()
public MemorySize getFrameworkHeapSize()
public MemorySize getFrameworkOffHeapMemorySize()
public MemorySize getTaskHeapSize()
public MemorySize getTaskOffHeapSize()
public MemorySize getNetworkMemSize()
public MemorySize getManagedMemorySize()
public MemorySize getJvmMetaspaceSize()
public MemorySize getJvmOverheadSize()
public MemorySize getTotalFlinkMemorySize()
public MemorySize getTotalProcessMemorySize()
public MemorySize getJvmHeapMemorySize()
public MemorySize getJvmDirectMemorySize()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.