Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2085
I quickly tried your changes.
Some notes
(1) When listing the yarn-session.sh cli options, I could not see the
newly added argument
```
./bin/yarn-session.sh
2016-06-10 09:28:37,186 ERROR org.apache.flink.yarn.cli.FlinkYarnSessionCli
- Missing required argument n
Usage:
Required
-n,--container <arg> Number of YARN container to allocate (=Number
of Task Managers)
Optional
-D <arg> Dynamic properties
-d,--detached Start detached
-jm,--jobManagerMemory <arg> Memory for JobManager Container [in MB]
-nm,--name <arg> Set a custom name for the application
on YARN
-q,--query Display available YARN resources
(memory, cores)
-qu,--queue <arg> Specify YARN queue.
-s,--slots <arg> Number of slots per TaskManager
-st,--streaming Start Flink in streaming mode
-tm,--taskManagerMemory <arg> Memory per TaskManager Container [in
MB]
Error while starting the YARN Client. Please check log output!
```
(2) Starting a YARN session works. Also, connecting with a second YARN
session works. However, if I'm stopping the session from the second session
client, the first one does not notice this.
It would be good if all connected clients receive the messages, instead of
the last one connected.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
