Re: Load distribution through the cluster

[Chesnay Schepler]

It should only apply to the map operator.

On 19.09.2017 17:38, AndreaKinn wrote:

If I apply a sharing slot as in the example:

DataStream<Event> LTzAccStream = env
                                .addSource(new FlinkKafkaConsumer010<>("topic", 
new
CustomDeserializer(), properties))
                                .assignTimestampsAndWatermarks(new 
CustomTimestampExtractor())
                                .map(new MapFunction<Tuple2&lt;String, String>, 
Event>(){
                                       @Override
                                        public Event map(Tuple2<String, String> 
value) throws Exception {
                                                return new Event(value.f0, 
value.f1);
                                        }
                                }).slotSharingGroup("group1");

just the map operator is assigned to the shared slot or it happens for the
entire block (addSource + assignTimestamp + map)?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/