Re: Using Custom Partitioner in Streaming with parallelism 1 adding latency

2017-06-27 Thread Aljoscha Krettek
from map -> custom partition -> flat map can take more > than 200 seconds if parallelism is still 1 . > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Using-Custom-Partitioner-in-Streaming-with-parallelism-1-addi

Re: Using Custom Partitioner in Streaming with parallelism 1 adding latency

2017-06-18 Thread sohimankotia
ailing-list-archive.2336050.n4.nabble.com/Using-Custom-Partitioner-in-Streaming-with-parallelism-1-adding-latency-tp13766p13822.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Using Custom Partitioner in Streaming with parallelism 1 adding latency

2017-06-16 Thread Aljoscha Krettek
> > > > > > -- > 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-tp13766p13774.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

Re: Using Custom Partitioner in Streaming with parallelism 1 adding latency

2017-06-15 Thread sohimankotia
pty as of now . -- 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-tp13766p13774.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Using Custom Partitioner in Streaming with parallelism 1 adding latency

2017-06-15 Thread Aljoscha Krettek
elay 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-Cust

Using Custom Partitioner in Streaming with parallelism 1 adding latency

2017-06-15 Thread sohimankotia
-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.