[jira] [Created] (FLINK-1921) Rework parallelism/slots handling for per-job YARN sessions

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1921) Rework parallelism/slots handling for per-job YARN sessions

Shang Yuanchun (Jira)
Robert Metzger created FLINK-1921:
-------------------------------------

             Summary: Rework parallelism/slots handling for per-job YARN sessions
                 Key: FLINK-1921
                 URL: https://issues.apache.org/jira/browse/FLINK-1921
             Project: Flink
          Issue Type: Bug
          Components: YARN Client
            Reporter: Robert Metzger


Right now, the -p argument is overwriting the -ys argument for per job yarn sessions.


Also, the priorities for parallelism should be documented:
low to high
1. flink-conf.yaml (-D arguments on YARN)
2. -p on ./bin/flink
3. ExecutionEnvironment.setParallelism()
4. Operator.setParallelism().



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)