Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18993

Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

    XMLWordPrintableJSON

    Details

      Description

      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);
      

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                wooplevip Peng
                Reporter:
                wooplevip Peng
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: