Hi, I have streaming job which is running with parallelism 1 as of now . (This job will run with parallelism > 1 in future )
So I have added custom partitioner to partition the data based on one tuple field . The flow is : source -> map -> partitioner -> flatmap -> sink The partitioner is adding around 40 sec or more delay for 40% of data (from map to flatmap ). I am not able to understand if parallelism is one how this delay is getting added . -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Using-Custom-Partitioner-in-Streaming-with-parallelism-1-adding-latency-tp13766.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
