This is an automated email from the ASF dual-hosted git repository.
leonard pushed a commit to branch release-3.2
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.2 by this push:
new 2b5d3f319 [hotfix][runtime] Invalidate cache correctly to avoid
classloader leakage
2b5d3f319 is described below
commit 2b5d3f3198f51cb91033b167ebc718f28cc4fd1d
Author: yuxiqian <[email protected]>
AuthorDate: Tue Aug 13 13:55:45 2024 +0800
[hotfix][runtime] Invalidate cache correctly to avoid classloader leakage
This closes #3534
---
.../cdc/runtime/operators/transform/TransformExpressionCompiler.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java
b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java
index e22d7943d..326ae7ba7 100644
---
a/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java
+++
b/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java
@@ -39,7 +39,10 @@ public class TransformExpressionCompiler {
/** Triggers internal garbage collection of expired cache entries. */
public static void cleanUp() {
- COMPILED_EXPRESSION_CACHE.cleanUp();
+ // com.google.common.cache.Cache from Guava isn't guaranteed to clear
all cached records
+ // when invoking Cache#cleanUp, which may cause classloader leakage.
Use #invalidateAll
+ // instead to ensure all key / value pairs to be correctly discarded.
+ COMPILED_EXPRESSION_CACHE.invalidateAll();
}
/** Compiles an expression code to a janino {@link ExpressionEvaluator}. */
