flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2598) NPE when arguments are missing for a "-m yarn-cluster" job
Date Sun, 30 Aug 2015 13:46:45 GMT
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

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

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 /
13:05:50,605 ERROR org.apache.flink.client.FlinkYarnSessionCli                   - Missing
required argument yn
     -yn,--yarncontainer <arg>   Number of YARN container to allocate (=Number of Task
     -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]
	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.

This message was sent by Atlassian JIRA

View raw message