[FLINK-11640] Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute. - ASF JIRA

XML

Word

Printable

JSON

Type: Bug
Status: Closed
Priority: Minor
Resolution: Not A Problem
Affects Version/s: 1.7.1
Fix Version/s: None
Component/s: API / DataStream
Labels:
None
Environment:

Hide

).centos 7,jdk 1.8

).Run command :

  flink run flink-maven-stala-2-0.0.1.jar com.opensourceteams.module.bigdata.flink.example.stream.worldcount.nc.Run

).link-maven-stala-2-0.0.1.jar

jar Function description, this function is the official website example, wordcount, but I will report an error when I run in the Flink cluster, and it can run normally in the idea.

Show
).centos 7,jdk 1.8 ).Run command :   flink run flink-maven-stala-2-0.0.1.jar com.opensourceteams.module.bigdata.flink.example.stream.worldcount.nc.Run ).link-maven-stala-2-0.0.1.jar   jar Function description, this function is the official website example, wordcount, but I will report an error when I run in the Flink cluster, and it can run normally in the idea.

Release Note:

Hide
Thank you very much, I understand, this is not a problem with Flink, it is my own problem, I am not the correct way to specify the main class, need -c to specify the entry class, example ok,

flink run -c com.opensourceteams.module.bigdata.flink.example.stream.worldcount.nc.SocketWindowWordCount ./flink-maven-scala-2-0.0.1.jar FirstJob

Show
Thank you very much, I understand, this is not a problem with Flink, it is my own problem, I am not the correct way to specify the main class, need -c to specify the entry class, example ok, flink run -c com.opensourceteams.module.bigdata.flink.example.stream.worldcount.nc.SocketWindowWordCount ./flink-maven-scala-2-0.0.1.jar FirstJob

Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.