flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robert Metzger (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4824) CliFrontend shows misleading error message when main() method returns before env.execute()
Date Thu, 13 Oct 2016 12:21:20 GMT
Robert Metzger created FLINK-4824:

             Summary: 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

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


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