Robert Metzger created FLINK-2598:
-------------------------------------
Summary: NPE when arguments are missing for a "-m yarn-cluster" job
Key: FLINK-2598
URL: https://issues.apache.org/jira/browse/FLINK-2598
Project: Flink
Issue Type: Bug
Affects Versions: 0.9.1
Reporter: Robert Metzger
Priority: Minor
Fix For: 0.9.2
Flink is properly reporting that the argument is missing.
Its "just" showing an ugly NPE exception, but this is not limiting the
functionality in any way.
The error does not occur in version: 0.10-SNAPSHOT, rev:6e1de98.
I'm adding this bug in case we are going to release 0.9.2
{code}
robert@cdh544-master:~/release091-rc1/flink-0.9.1/build-target$ ./bin/flink run
-m yarn-cluster ./examples/flink-java-examples-0.9.1-WordCount.jar
hdfs:///user/robert/kmeans/points hdfs:///user/robert/garbage
YARN cluster mode detected. Switching Log4j output to console
13:05:50,432 INFO org.apache.hadoop.yarn.client.RMProxy
- Connecting to ResourceManager at /0.0.0.0:8032
13:05:50,605 ERROR org.apache.flink.client.FlinkYarnSessionCli
- Missing required argument yn
Usage:
Required
-yn,--yarncontainer <arg> Number of YARN container to allocate (=Number
of Task Managers)
Optional
-yd,--yarndetached Start detached
-yD <arg> Dynamic properties
-yjm,--yarnjobManagerMemory <arg> Memory for JobManager Container [in
MB]
-ynm,--yarnname <arg> Set a custom name for the application
on YARN
-yq,--yarnquery Display available YARN resources
(memory, cores)
-yqu,--yarnqueue <arg> Specify YARN queue.
-ys,--yarnslots <arg> Number of slots per TaskManager
-yst,--yarnstreaming Start Flink in streaming mode
-ytm,--yarntaskManagerMemory <arg> Memory per TaskManager Container [in
MB]
java.lang.NullPointerException
at org.apache.flink.client.CliFrontend.getClient(CliFrontend.java:735)
at org.apache.flink.client.CliFrontend.run(CliFrontend.java:271)
at
org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:878)
at org.apache.flink.client.CliFrontend.main(CliFrontend.java:920)
The exception above occurred while trying to run your command.
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
