[hotfix][core] Add/remove missing/incorrect serialVersionUID fields i…

…n Timestamp Assigner classes
zhengcanbin · May 20, 2020 · 7de9d20 · 7de9d20
1 parent be59c26
commit 7de9d20
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 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
@@ -28,7 +28,6 @@
  */
 @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
@@ -27,8 +27,6 @@
 @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/...k-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java b/...k-core/src/main/java/org/apache/flink/api/common/eventtime/TimestampAssignerSupplier.java
@@ -69,6 +69,9 @@ interface Context {
  * 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) {