dos-group/allocation-assistant

Use #cores/slots argument

Closed this issue · 2 comments

lauritzthamsen commented

There's already a command-line argument for setting the number of cores for containers (slots of Flink TaskManagers/Spark Executors), but it isn't submitted to YARN with jobs yet.

See
https://github.com/citlab/allocation-assistant/blob/master/src/main/scala/de/tuberlin/cit/allocationassistant/CommandRunner.scala#L27

Gjum commented

I have implemented this already for flink, will push after testing.

lauritzthamsen commented

done for Flink with a26c22f (by @Gjum)