[jira] [Created] (FLINK-8712) Cannot execute job with multiple slot sharing groups on LocalExecutor

[Shang Yuanchun (Jira)]

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)