flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sendoh <unicorn.bana...@gmail.com>
Subject Re: Cannot see all events in window apply() for big input
Date Mon, 07 Nov 2016 16:43:58 GMT
Hi Till.

Thank you for suggesting. We know the timestamp is correct because another
Flink job is running with the three topics correctly. We also know the
operators work well before window apply() because we check the result before
window apply().

What currently I have a doubt is the necessary parallelisms for window
operation if reprocessing a skew input from Kafka because it works with
fewer events, and small topics always appear while big topics disappear.



View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Cannot-see-all-events-in-window-apply-for-big-input-tp9945p9950.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message