[
https://issues.apache.org/jira/browse/FLINK-37576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37576:
-------------------------------
Description:
{code:java}
public class TestJob {
public static void main(String[] args) throws Exception {
Configuration conf = new Configuration();
// set min parallelism great then 1
conf.setString("execution.batch.adaptive.auto-parallelism.min-parallelism",
"2");
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment(conf);
// env.disableOperatorChaining();
// set to batch mode
env.setRuntimeMode(RuntimeExecutionMode.BATCH);
env.fromSequence(0, 10).broadcast().sinkTo(new DiscardingSink<>());
JobGraphRunningUtil.execute(env.getStreamGraph().getJobGraph(), conf,
2, 10);
}
} {code}
> Batch job failed when submit JobGraph contains broadcast edge
> -------------------------------------------------------------
>
> Key: FLINK-37576
> URL: https://issues.apache.org/jira/browse/FLINK-37576
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 2.0.0
> Reporter: Weijie Guo
> Priority: Major
>
> {code:java}
> public class TestJob {
> public static void main(String[] args) throws Exception {
> Configuration conf = new Configuration();
> // set min parallelism great then 1
>
> conf.setString("execution.batch.adaptive.auto-parallelism.min-parallelism",
> "2");
> StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment(conf);
> // env.disableOperatorChaining();
> // set to batch mode
> env.setRuntimeMode(RuntimeExecutionMode.BATCH);
> env.fromSequence(0, 10).broadcast().sinkTo(new DiscardingSink<>());
> JobGraphRunningUtil.execute(env.getStreamGraph().getJobGraph(), conf,
> 2, 10);
> }
> } {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
