taoran92 commented on PR #4422:
URL: https://github.com/apache/flink-cdc/pull/4422#issuecomment-5250537834
Thanks for reviewing. @leonardBang @loserwang1024 @ruanhang1993
I have introduced a bounded CachedTableFilter in flink-connector-debezium
and use it as the default relational table filter.
For withAdditionalFilter() , it combines the raw Debezium delegate with the
additional exclude rule and creates a single new cache. It first copies the raw
delegate to a local variable, so the lambda does not capture or retain the
previous CachedTableFilter and its cache. So the old cache can be GC. cc
@ruanhang1993
All tests passed. PTAL, thanks.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
