[hotfix][runtime] Invalidate cache correctly to avoid classloader lea…

…kage
apache · Aug 13, 2024 · 9c0b8d1 · 9c0b8d1
1 parent 1042095
commit 9c0b8d1
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...in/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java b/...in/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}. */