flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sohimankotia <sohimanko...@gmail.com>
Subject Re: Using Custom Partitioner in Streaming with parallelism 1 adding latency
Date Fri, 16 Jun 2017 04:42:52 GMT
You are right Aljoscha . Jog graph is splitted after introducing partitioner
.

I was under impression that If parallelism is set everything will be chained
together .
Can you explain how data will flow for  map -> partitioner -> flatmap  if
parallelism or It would be great if point me to right documentation ?

Can is this possible it can add more than 100 seconds delay if partitioner
is added ?

Sorry for dumb question but I did not find any detailed documentation on
flink website . Most of links
https://cwiki.apache.org/confluence/display/FLINK/Parallelism+and+Scheduling
are also empty 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.

Mime
View raw message