-
Type:
Bug
-
Status: Closed
-
Priority:
Critical
-
Resolution: Fixed
-
Affects Version/s: 1.11.0
-
Component/s: Runtime / Configuration
-
Labels:
In deriveFromRequiredFineGrainedOptions method from JobManagerFlinkMemoryUtils.java, it will call sanityCheckTotalFlinkMemory method to check heap, off-heap and total memory as below.
sanityCheckTotalFlinkMemory(totalFlinkMemorySize, jvmHeapMemorySize, totalFlinkMemorySize);
As I understand it, the third argument should be offHeapMemorySize.
sanityCheckTotalFlinkMemory(totalFlinkMemorySize, jvmHeapMemorySize, offHeapMemorySize);
- links to