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/05/20 15:24:41 UTC
[flink] 02/03: [hotfix][core] Add/remove missing/incorrect
serialVersionUID fields in Timestamp Assigner classes
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 7de9d204d8973f488c1f257002f47c78ca9e6a4f
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue May 19 18:52:38 2020 +0200
[hotfix][core] Add/remove missing/incorrect serialVersionUID fields in Timestamp Assigner classes
---
.../org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java | 1 -
.../org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java | 2 --
.../apache/flink/api/common/eventtime/TimestampAssignerSupplier.java | 3 +++
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java
index 77c400e..b6c81ea 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/IngestionTimeAssigner.java
@@ -28,7 +28,6 @@ import org.apache.flink.annotation.Public;
*/
@Public
public final class IngestionTimeAssigner<T> implements TimestampAssigner<T> {
- private static final long serialVersionUID = 1L;
private long maxTimestamp;
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java
index 1be7c07..75ee1e8 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/RecordTimestampAssigner.java
@@ -27,8 +27,6 @@ import org.apache.flink.annotation.Public;
@Public
public final class RecordTimestampAssigner<E> implements TimestampAssigner<E> {
- private static final long serialVersionUID = 1L;
-
@Override
public long extractTimestamp(E element, long recordTimestamp) {
return recordTimestamp;
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
index d72cc9f..15f2af0 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
@@ -69,6 +69,9 @@ public interface TimestampAssignerSupplier<T> extends Serializable {
* into the {@link SerializableTimestampAssigner}.
*/
class SupplierFromSerializableTimestampAssigner<T> implements TimestampAssignerSupplier<T> {
+
+ private static final long serialVersionUID = 1L;
+
private final SerializableTimestampAssigner<T> assigner;
public SupplierFromSerializableTimestampAssigner(SerializableTimestampAssigner<T> assigner) {