You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/07/04 07:10:39 UTC
[flink] 08/11: [FLINK-12963] [state-processor] Add missing
serialVersionUIDs
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit cb535d9b6ea24b8419bb5dffb7a090da8e709589
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Thu Jul 4 03:19:20 2019 +0800
[FLINK-12963] [state-processor] Add missing serialVersionUIDs
---
.../apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java | 3 +++
.../java/org/apache/flink/state/api/output/MergeOperatorStates.java | 3 +++
.../org/apache/flink/state/api/output/OperatorSubtaskStateReducer.java | 2 ++
.../java/org/apache/flink/state/api/runtime/BoundedStreamConfig.java | 3 +++
4 files changed, 11 insertions(+)
diff --git a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java
index f6d5093..c975e6d 100644
--- a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java
+++ b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedOneInputStreamTaskRunner.java
@@ -38,6 +38,9 @@ import org.apache.flink.util.Collector;
*/
@Internal
public class BoundedOneInputStreamTaskRunner<IN> extends RichMapPartitionFunction<IN, TaggedOperatorSubtaskState> {
+
+ private static final long serialVersionUID = 1L;
+
private final StreamConfig streamConfig;
private final int maxParallelism;
diff --git a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/MergeOperatorStates.java b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/MergeOperatorStates.java
index 81b49b2..d5789a3 100644
--- a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/MergeOperatorStates.java
+++ b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/MergeOperatorStates.java
@@ -36,6 +36,9 @@ import java.util.stream.StreamSupport;
*/
@Internal
public class MergeOperatorStates implements GroupReduceFunction<OperatorState, Savepoint> {
+
+ private static final long serialVersionUID = 1L;
+
private final Collection<MasterState> masterStates;
public MergeOperatorStates(Collection<MasterState> masterStates) {
diff --git a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/OperatorSubtaskStateReducer.java b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/OperatorSubtaskStateReducer.java
index bfd06b3..1ac57f5 100644
--- a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/OperatorSubtaskStateReducer.java
+++ b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/OperatorSubtaskStateReducer.java
@@ -39,6 +39,8 @@ import java.util.stream.StreamSupport;
public class OperatorSubtaskStateReducer
extends RichGroupReduceFunction<TaggedOperatorSubtaskState, OperatorState> {
+ private static final long serialVersionUID = 1L;
+
private final OperatorID operatorID;
private final int maxParallelism;
diff --git a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/BoundedStreamConfig.java b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/BoundedStreamConfig.java
index 6306447..5f3b38b 100644
--- a/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/BoundedStreamConfig.java
+++ b/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/BoundedStreamConfig.java
@@ -30,6 +30,9 @@ import org.apache.flink.streaming.api.graph.StreamConfig;
*/
@Internal
public class BoundedStreamConfig extends StreamConfig {
+
+ private static final long serialVersionUID = 1L;
+
public BoundedStreamConfig() {
super(new Configuration());