azagrebin commented on a change in pull request #8459: [FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig URL: https://github.com/apache/flink/pull/8459#discussion_r287807783
########## File path: docs/dev/stream/state/state.md ########## @@ -483,11 +513,12 @@ val ttlConfig = StateTtlConfig </div> RocksDB compaction filter will query current timestamp, used to check expiration, from Flink every time -after processing certain number of state entries. This number is 1000 by default. +after processing certain number of state entries. You can optionally change it and pass a custom value to `StateTtlConfig.newBuilder(...).cleanupInRocksdbCompactFilter(long queryTimeAfterNumEntries)` method. Updating the timestamp more often can improve cleanup speed but it decreases compaction performance because it uses JNI call from native code. +If you enable the default background cleanup then this strategy will be activated for RocksDB backend with 1000 number of state entries every time after processing. Review comment: `this strategy will be activated for RocksDB backend and the current timestamp will be queried each time 1000 entries have been processed.` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
