[jira] [Created] (FLINK-18157) Jobstore size check compares against offHeapMemory

["Chesnay Schepler (Jira)" <ji...@apache.org>]

Chesnay Schepler created FLINK-18157:
----------------------------------------

             Summary: Jobstore size check compares against offHeapMemory
                 Key: FLINK-18157
                 URL: https://issues.apache.org/jira/browse/FLINK-18157
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Coordination
    Affects Versions: 1.11.0
            Reporter: Chesnay Schepler


Setting {{jobmanager.memory.off-heap.size}} to 0 results in this confusing error:
{code}
[] - Loading configuration property: jobmanager.memory.process.size, 2000m
[] - Loading configuration property: jobmanager.memory.heap.size, 1500m
[] - Loading configuration property: jobmanager.memory.jvm-overhead.min, 100m
[] - Loading configuration property: jobmanager.memory.jvm-overhead.max, 350m
[] - Loading configuration property: jobmanager.memory.off-heap.size, 0m
[] - The configured or derived JVM heap memory size (jobstore.cache-size: 0 bytes) is less than the configured or default size of the job store cache (jobmanager.memory.heap.size: 50.000mb (52428800 bytes))
{code}

According to the documentation the jobstore uses the heap though.

{code}
private static JobManagerFlinkMemory createJobManagerFlinkMemory(
		Configuration config,
		MemorySize jvmHeap,
		MemorySize offHeapMemory) {
	verifyJvmHeapSize(jvmHeap);
	verifyJobStoreCacheSize(config, offHeapMemory);
	return new JobManagerFlinkMemory(jvmHeap, offHeapMemory);
}

private static void verifyJvmHeapSize(MemorySize jvmHeapSize) {
	if (jvmHeapSize.compareTo(JobManagerOptions.MIN_JVM_HEAP_SIZE) < 1) {
		LOG.warn(
			"The configured or derived JVM heap memory size ({}) is less than its recommended minimum value ({})",
			jvmHeapSize.toHumanReadableString(),
			JobManagerOptions.MIN_JVM_HEAP_SIZE);
	}
}
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)