Till Rohrmann created FLINK-8712:
------------------------------------
Summary: Cannot execute job with multiple slot sharing groups on
LocalExecutor
Key: FLINK-8712
URL: https://issues.apache.org/jira/browse/FLINK-8712
Project: Flink
Issue Type: Bug
Components: Local Runtime
Affects Versions: 1.5.0
Reporter: Till Rohrmann
Currently, it is not possible to run a job with multiple slot sharing groups on
the LocalExecutor. The problem is that we determine the number of required
slots simply by looking for the max parallelism of the job but do not consider
slot sharing groups.
{code:java}
// set up the streaming execution environment
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(1);
final DataStreamSource<Integer> input = env.addSource(new InfinitySource());
final SingleOutputStreamOperator<Integer> different = input.map(new
MapFunction<Integer, Integer>() {
@Override
public Integer map(Integer integer) throws Exception {
return integer;
}
}).slotSharingGroup("Different");
different.print();
// execute program
env.execute("Flink Streaming Java API Skeleton");{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
