[FLINK-4824] CliFrontend shows misleading error message when main() method returns before env.execute()

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0
• Fix Version/s: 1.2.0
• Component/s: Command Line Client
• Assignee: Greg Hogan
• Reporter: Robert Metzger
• Created: 13/Oct/16 12:21
• Updated: 24/Oct/16 15:21
• Resolved: 24/Oct/16 15:21

Description

While testing Flink by running the ./examples/streaming/SocketWindowWordCount.jar example, I got the following error message:

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

I think the error message is misleading, because I tried executing a valid Flink job.

Issue Links

• links to: GitHub Pull Request #2662