Ismaël Mejía created BEAM-7325:
----------------------------------
Summary: PipelineTest.testEmptyPipeline breaks on Flink runner
Key: BEAM-7325
URL: https://issues.apache.org/jira/browse/BEAM-7325
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Ismaël Mejía
{code}
org.apache.beam.sdk.Pipeline$PipelineExecutionException
:
java.lang.IllegalStateException: No operators defined in streaming topology.
Cannot execute.
Open stacktrace
Caused by:
java.lang.IllegalStateException
:
No operators defined in streaming topology. Cannot execute.
Close stacktrace
at
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1534)
at
org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:89)
at
org.apache.beam.runners.flink.FlinkPipelineExecutionEnvironment.executePipeline(FlinkPipelineExecutionEnvironment.java:141)
at org.apache.beam.runners.flink.FlinkRunner.run(FlinkRunner.java:113)
}code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
