Hi all, I tried starting a local Flink 1.2.0 cluster using start-local.sh, with the following settings for the taskmanager memory:
taskmanager.heap.mb: 16384 taskmanager.memory.off-heap: true taskmanager.memory.preallocate: true That throws and OOM error: Caused by: java.lang.Exception: OutOfMemory error (Direct buffer memory) while allocating the TaskManager off-heap memory (39017161219 bytes). Try increasing the maximum direct memory (-XX:MaxDirectMemorySize) However If I add an obsolute taskmanager.memory.size: taskmanager.memory.size: 15360 the cluster starts successfully. My understanding is that if taskmanager.memory.size is unspecified then it should be equal to 0.7 * taskmanager.heap.mb. So I don't understand why it throws an exception and it works if its larger than that fraction. Any help is appreciated. Best, Yassine