Hello,

I'm tuning flink for parallelism right now and when I look at the
JobManager I see
*taskmanager.cpu.cores* 1.7976931348623157E308
Which looks like the maximum double number.

We have 8 cpu cores, so we figured we'd bump to 16 for hyper threading. We
have 37 operators so we rounded up and set 40 task slots.

Here is our configuration

"vmArgs": "-Xmx16g -Xms16g -XX:MaxDirectMemorySize=1207959552
-XX:MaxMetaspaceSize=268435456 -Dlog.file=/tmp/flink.log
-Dtaskmanager.memory.framework.off-heap.size=134217728b
-Dtaskmanager.memory.network.max=1073741824b
-Dtaskmanager.memory.network.min=1073741824b
-Dtaskmanager.memory.framework.heap.size=134217728b
-Dtaskmanager.memory.managed.size=6335076856b
-Dtaskmanager.memory.task.heap.size=8160437768b
-Dtaskmanager.memory.task.off-heap.size=0b
-Dtaskmanager.numberOfTaskSlots=40 -Dtaskmanager.cpu.cores=16.0"

We then tried with -Dtaskmanager.cpu.cores=7.0 and still ended up with that
very odd value for cpu cores.

How do we correctly adjust this?

Thanks!
-- 

Rex Fenley  |  Software Engineer - Mobile and Backend


Remind.com <https://www.remind.com/> |  BLOG <http://blog.remind.com/>
 |  FOLLOW
US <https://twitter.com/remindhq>  |  LIKE US
<https://www.facebook.com/remindhq>

Reply via email to