public class TaskExecutorProcessSpec extends CommonProcessMemorySpec<TaskExecutorFlinkMemory>
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 ││ └─────────────────────────────┘ └ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ─ ┘
Modifier | Constructor and Description |
---|---|
|
TaskExecutorProcessSpec(CPUResource cpuCores,
MemorySize frameworkHeapSize,
MemorySize frameworkOffHeapSize,
MemorySize taskHeapSize,
MemorySize taskOffHeapSize,
MemorySize networkMemSize,
MemorySize managedMemorySize,
MemorySize jvmMetaspaceSize,
MemorySize jvmOverheadSize) |
protected |
TaskExecutorProcessSpec(CPUResource cpuCores,
TaskExecutorFlinkMemory flinkMemory,
JvmMetaspaceAndOverhead jvmMetaspaceAndOverhead) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
CPUResource |
getCpuCores() |
MemorySize |
getManagedMemorySize() |
MemorySize |
getNetworkMemSize() |
MemorySize |
getTaskHeapSize() |
MemorySize |
getTaskOffHeapSize() |
int |
hashCode() |
String |
toString() |
getFlinkMemory, getJvmDirectMemorySize, getJvmHeapMemorySize, getJvmMetaspaceAndOverhead, getJvmMetaspaceSize, getJvmOverheadSize, getTotalFlinkMemorySize, getTotalProcessMemorySize
@VisibleForTesting public TaskExecutorProcessSpec(CPUResource cpuCores, MemorySize frameworkHeapSize, MemorySize frameworkOffHeapSize, MemorySize taskHeapSize, MemorySize taskOffHeapSize, MemorySize networkMemSize, MemorySize managedMemorySize, MemorySize jvmMetaspaceSize, MemorySize jvmOverheadSize)
protected TaskExecutorProcessSpec(CPUResource cpuCores, TaskExecutorFlinkMemory flinkMemory, JvmMetaspaceAndOverhead jvmMetaspaceAndOverhead)
public CPUResource getCpuCores()
public MemorySize getTaskHeapSize()
public MemorySize getTaskOffHeapSize()
public MemorySize getNetworkMemSize()
public MemorySize getManagedMemorySize()
public boolean equals(Object obj)
equals
in class CommonProcessMemorySpec<TaskExecutorFlinkMemory>
public int hashCode()
hashCode
in class CommonProcessMemorySpec<TaskExecutorFlinkMemory>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.