You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 15:59:27 UTC
[jira] [Closed] (FLINK-2598) NPE when arguments are missing for a
"-m yarn-cluster" job
[ https://issues.apache.org/jira/browse/FLINK-2598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robert Metzger closed FLINK-2598.
---------------------------------
Resolution: Won't Fix
Fix Version/s: (was: 0.9.2)
> 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
>
> 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)