flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From burgesschen <tchen...@bloomberg.net>
Subject Ever increasing key space
Date Mon, 16 Jul 2018 15:57:42 GMT
Hi every one,

We are building a flink job that keys on a dynamic value. Only a few events
share the same key and events with new keys are consumed constantly.

For each key, there are some keyedState created the first time it is seen.
And we clean up the keyedState if the key has not been seen for X minutes
using a timer.

My question is:
If the key space is ever increasing? Does it result in an ever increasing
checkpoint size even I clean up the keyedState? 

Thank you!


Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

View raw message