Re: Load distribution through the cluster

[AndreaKinn]

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/