migrating our flink project from 1.8 to 1.17.
>
> The cleanUpInRocksDbCompactFilter() now accepts longtimeNumberOfQueries()
> as parameter. The question is how would we know the right value. We set to
> 1000 temporarily, is there a default value to set.
>
>
> Regards,
> Patricia
>
--
Best,
Hangxiang.
Hi,
I am currently migrating our flink project from 1.8 to 1.17.
The cleanUpInRocksDbCompactFilter() now accepts longtimeNumberOfQueries()
as parameter. The question is how would we know the right value. We set to
1000 temporarily, is there a default value to set.
Regards,
Patricia
checkpoint, can investigate
more from TM log);
Best
Congxian
On May 9, 2019, 14:44 +0800, Mu Kong , wrote:
> Hi community,
>
> I'm glad that in Flink 1.8.0, it introduced cleanupInRocksdbCompactFilter to
> support state clean up for rocksdb backend.
> We have an application th
Hi community,
I'm glad that in Flink 1.8.0, it introduced cleanupInRocksdbCompactFilter
to support state clean up for rocksdb backend.
We have an application that heavily relies on managed keyed store.
As we are using rocksdb as the state backend, we were suffering the issue
of ever-growing
