Hi,
I think it would be easier to implement a custom key selector and
introduce some artifical key that spreads the load more evenly. This
would also allow you to use keyed state. You could use a ProcessFunction
and set timers to define the "every now and then". Keyed state would
also ease the state redistribution in case the parallelism changes.
Maybe could could also do the summary merge in some downstream
operators. Maybe this talk [1] gives you some additional inspiration.
Regards,
Timo
[1] https://www.youtube.com/watch?v=Do7C4UJyWCM
Am 2/1/18 um 9:31 AM schrieb m@xi:
Anyone, someone, somebody?
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
