You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/10/02 22:22:22 UTC
[flink] 01/04: [hotfix][DataStream API] Remove ineffective and
unneeded Serializability from StreamNode.
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1296296c1bea235f96e48067c22a29f6f52ef482
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue Sep 29 20:03:27 2020 +0200
[hotfix][DataStream API] Remove ineffective and unneeded Serializability from StreamNode.
The StreamNode implements Serializable, but contains non-serializable structures.
---
.../main/java/org/apache/flink/streaming/api/graph/StreamNode.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
index 0c8b90e..89f6fe7 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java
@@ -35,7 +35,6 @@ import org.apache.flink.streaming.api.operators.StreamOperatorFactory;
import javax.annotation.Nullable;
-import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
@@ -51,9 +50,7 @@ import static org.apache.flink.util.Preconditions.checkArgument;
* Class representing the operators in the streaming programs, with all their properties.
*/
@Internal
-public class StreamNode implements Serializable {
-
- private static final long serialVersionUID = 1L;
+public class StreamNode {
private final int id;
private int parallelism;
@@ -73,7 +70,7 @@ public class StreamNode implements Serializable {
private KeySelector<?, ?>[] statePartitioners = new KeySelector[0];
private TypeSerializer<?> stateKeySerializer;
- private transient StreamOperatorFactory<?> operatorFactory;
+ private StreamOperatorFactory<?> operatorFactory;
private TypeSerializer<?>[] typeSerializersIn = new TypeSerializer[0];
private TypeSerializer<?> typeSerializerOut;