Hello everyone,

I've got a question for you all. When Flink attempts to obtain the current 
number of available CPU cores through the Java runtime 
(Runtime.getRuntime().availableProcessors()), an issue arises. Specifically, 
when running multiple Flink jobs, either version 1.13 or 1.17, on Yarn, we've 
noticed that some jobs retrieve the total number of cores of the entire 
machine, while others only get the cores allocated to the Yarn container. This 
discrepancy occurs regardless of whether it's Flink 1.13 or 1.17. Could anyone 
tell me what might be causing this?

Here's the environmental information:

Flink versions: Flink 1.13 and Flink 1.17
Hadoop: Version 2.6.0
Java: Version 1.8
Thank you!



Best regards,
Vincent Woo

Reply via email to