flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()
Date Thu, 20 Oct 2016 09:10:58 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15591288#comment-15591288

ASF GitHub Bot commented on FLINK-4824:

Github user mxm commented on the issue:

    Thanks for the PR @greghogan! Having a custom exception for missing arguments to a user
program is a good approach. However, it requires the author of the program to use the custom
exception. At least, we would have to adapt all the included examples. Additionally, it would
be nice to throw another custom exception when no Flink job was generated during execution
of the jar (which might be because of missing arguments). Currently, we simply throw a `ProgramInvocationException`
which could look like a serious error to the user when merely arguments are missing. 
    So +1 but we might do some follow-ups to fully solve the issue.

> CliFrontend shows misleading error message when main() method returns before env.execute()
> ------------------------------------------------------------------------------------------
>                 Key: FLINK-4824
>                 URL: https://issues.apache.org/jira/browse/FLINK-4824
>             Project: Flink
>          Issue Type: Bug
>          Components: Client
>    Affects Versions: 1.2.0
>            Reporter: Robert Metzger
>            Assignee: Greg Hogan
> While testing Flink by running the {{./examples/streaming/SocketWindowWordCount.jar}}
example, I got the following error message:
> {code}
> ./bin/flink run ./examples/streaming/SocketWindowWordCount.jar 
> Cluster configuration: Standalone cluster with JobManager at /
> Using address to connect to JobManager.
> JobManager web interface address
> Starting execution of program
> No port specified. Please run 'SocketWindowWordCount --port <port>', where port
is the address of the text server
> To start a simple text server, run 'netcat -l <port>' and type the input text into
the command line
> ------------------------------------------------------------
>  The program finished with the following exception:
> org.apache.flink.client.program.ProgramInvocationException: The program didn't contain
Flink jobs. Perhaps you forgot to call execute() on the execution environment.
> 	at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:324)
> 	at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:774)
> 	at org.apache.flink.client.CliFrontend.run(CliFrontend.java:250)
> 	at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:985)
> 	at org.apache.flink.client.CliFrontend$2.run(CliFrontend.java:1032)
> 	at org.apache.flink.client.CliFrontend$2.run(CliFrontend.java:1029)
> 	at org.apache.flink.runtime.security.SecurityContext$1.run(SecurityContext.java:82)
> 	at java.security.AccessController.doPrivileged(Native Method)
> 	at javax.security.auth.Subject.doAs(Subject.java:422)
> 	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1548)
> 	at org.apache.flink.runtime.security.SecurityContext.runSecured(SecurityContext.java:79)
> 	at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1029)
> {code}
> I think the error message is misleading, because I tried executing a valid Flink job.

This message was sent by Atlassian JIRA

View raw message