You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2019/02/18 08:29:00 UTC
[jira] [Commented] (FLINK-11640) Caused by:
java.lang.IllegalStateException: No operators defined in streaming
topology. Cannot execute.
[ https://issues.apache.org/jira/browse/FLINK-11640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16770860#comment-16770860 ]
Robert Metzger commented on FLINK-11640:
----------------------------------------
Thanks a lot for this bug report.
I'm proposing to close this ticket, as the issue you are reporting does not seem to be an issue in Flink, but rather in the user code.
Can you ask on the [user@flink.apache.org|mailto:user@flink.apache.org] mailing list for help on the issue? Most likely, you are calling an {{execute()}} method in your user-code which is not connected to any data sources (maybe you have two ExecutionEnvironments, or no sources connected to your environment)
> Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.
> -------------------------------------------------------------------------------------------------------
>
> Key: FLINK-11640
> URL: https://issues.apache.org/jira/browse/FLINK-11640
> Project: Flink
> Issue Type: Bug
> Components: DataStream API
> Affects Versions: 1.7.1
> Environment: ).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.
> Reporter: thinktothings
> Priority: Minor
> Attachments: 屏幕快照 2019-02-17 下午6.37.16.png
>
>
> Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)