[hotfix] Clean broadcast functions when translating.

This closes apache#5477.
mpdn · Feb 13, 2018 · 010f44c · 010f44c
1 parent cd6fe1c
commit 010f44c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ava/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java b/...ava/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java
@@ -161,7 +161,7 @@ public <KS, OUT> SingleOutputStreamOperator<OUT> process(
 				"A KeyedBroadcastProcessFunction can only be used with a keyed stream as the second input.");
 
 		TwoInputStreamOperator<IN1, IN2, OUT> operator =
-				new CoBroadcastWithKeyedOperator<>(function, broadcastStateDescriptors);
+				new CoBroadcastWithKeyedOperator<>(clean(function), broadcastStateDescriptors);
 		return transform("Co-Process-Broadcast-Keyed", outTypeInfo, operator);
 	}
 
@@ -212,7 +212,7 @@ public <OUT> SingleOutputStreamOperator<OUT> process(
 				"A BroadcastProcessFunction can only be used with a non-keyed stream as the second input.");
 
 		TwoInputStreamOperator<IN1, IN2, OUT> operator =
-				new CoBroadcastWithNonKeyedOperator<>(function, broadcastStateDescriptors);
+				new CoBroadcastWithNonKeyedOperator<>(clean(function), broadcastStateDescriptors);
 		return transform("Co-Process-Broadcast", outTypeInfo, operator);
 	}