So In following execution flow : source -> map -> partitioner -> flatmap -> sink
I am attaching current time to tuple while emitting from map function , and then extracting that timestamp value from tuple in flatmap at a very first step . Then I am calculating difference between time attached while emitting from map and entering into flatmap . -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Partitioner-is-spending-around-2-to-4-minutes-while-pushing-data-to-next-operator-tp13913p14025.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
