Re: Questions about slot sharing

2016-07-14 Thread Vincent Wang
le when you have a series of > mappers (or filters) running with the same parallelism. We call this > feature "operator chaining" [1] > > Regards, > Robert > > [1] > https://ci.apache.org/projects/flink/flink-docs-master/concepts/concepts.html#tasks--operator-chains &g

Questions about slot sharing

2016-07-14 Thread Vincent Wang
Hi all, I'm totally new to Flink and I got a question about Flink's slot sharing feature. Suppose I have a pipeline like *Mapper-> Reducer, *and of cause the operators are* not *chained to a single task. When the job is actually scheduled to the Flink cluster, there is a Mapper task and a Re