Chris Hogue created FLINK-4125:
----------------------------------
Summary: Yarn CLI incorrectly calculates slotsPerTM when
parallelism < task manager count
Key: FLINK-4125
URL: https://issues.apache.org/jira/browse/FLINK-4125
Project: Flink
Issue Type: Bug
Reporter: Chris Hogue
Priority: Minor
The FlinkYarnSessionCli class tries to calculate how many slots each
taskmanager gets based on the user-supplied parallelism option. It's using an
int, so when -p < -yn it is truncated to 0 and the cluster then fails to start,
saying slots per TM must be positive. And example command to trigger this would
be:
bin/flink run -m yarn-cluster -d -yn 20 -ys 2 -p 5 <a jar>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
