[runtime] Release additional broadcast variable references early

d9cb5b71 · Stephan Ewen · 26c9819e · d9cb5b71
隐藏空白更改
内联并排

Showing with 1 addition and 0 deletion

flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableMaterialization.java ...k/runtime/broadcast/BroadcastVariableMaterialization.java +1 -0

未找到文件。
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableMaterialization.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableMaterialization.java
@@ -191,6 +191,7 @@ public class BroadcastVariableMaterialization<T, C> {
 			if (references.isEmpty()) {
 				disposed = true;
 				data = null;
+				transformed = null;
 				return true;
 			} else {
 				return false;