[
https://issues.apache.org/jira/browse/FLINK-18157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Zagrebin closed FLINK-18157.
-----------------------------------
Fix Version/s: 1.11.0
Resolution: Fixed
merged into master by 040ce4be4c37652bebd28a75d97d903fca64616d
merged into 1.11 by 823720de4e75faf31f181722bdaaedc781f22d58
> 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
> Assignee: Nicholas Jiang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.11.0
>
>
> 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)
