public class JobManagerFlinkMemoryUtils extends Object implements FlinkMemoryUtils<JobManagerFlinkMemory>
FlinkMemoryUtils
for Job Manager.
The required fine-grained component is JobManagerOptions.JVM_HEAP_MEMORY
.
Constructor and Description |
---|
JobManagerFlinkMemoryUtils() |
Modifier and Type | Method and Description |
---|---|
JobManagerFlinkMemory |
deriveFromRequiredFineGrainedOptions(Configuration config) |
JobManagerFlinkMemory |
deriveFromTotalFlinkMemory(Configuration config,
MemorySize totalFlinkMemorySize) |
public JobManagerFlinkMemory deriveFromRequiredFineGrainedOptions(Configuration config)
deriveFromRequiredFineGrainedOptions
in interface FlinkMemoryUtils<JobManagerFlinkMemory>
public JobManagerFlinkMemory deriveFromTotalFlinkMemory(Configuration config, MemorySize totalFlinkMemorySize)
deriveFromTotalFlinkMemory
in interface FlinkMemoryUtils<JobManagerFlinkMemory>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.