You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/03 23:06:27 UTC

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14988240#comment-14988240 ] 

Chesnay Schepler commented on FLINK-2598:
-----------------------------------------

This issue can be closed, right [~rmetzger] ?

> 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)