[
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:
https://github.com/apache/flink/pull/2662
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 /127.0.0.1:6123
> Using address 127.0.0.1:6123 to connect to JobManager.
> JobManager web interface address http://127.0.0.1:8081
> 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
(v6.3.4#6332)
