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/01/30 14:54:10 UTC
[flink] 05/18: [hotfix] [e2e] Add missing serialVersionUIDs to
state TTL e2e test classes
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 d575951cff8c24c8a5ceb9e4dd44c9c0429aaee8
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Wed Jan 30 16:20:56 2019 +0800
[hotfix] [e2e] Add missing serialVersionUIDs to state TTL e2e test classes
---
.../org/apache/flink/streaming/tests/verify/ValueWithTs.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/verify/ValueWithTs.java b/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/verify/ValueWithTs.java
index 7070c6d..3574591 100644
--- a/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/verify/ValueWithTs.java
+++ b/flink-end-to-end-tests/flink-stream-state-ttl-test/src/main/java/org/apache/flink/streaming/tests/verify/ValueWithTs.java
@@ -30,6 +30,9 @@ import java.io.Serializable;
/** User state value with timestamps before and after update. */
public class ValueWithTs<V> implements Serializable {
+
+ private static final long serialVersionUID = -8941625260587401383L;
+
private final V value;
private final long timestamp;
@@ -57,6 +60,8 @@ public class ValueWithTs<V> implements Serializable {
/** Serializer for Serializer. */
public static class Serializer extends CompositeSerializer<ValueWithTs<?>> {
+ private static final long serialVersionUID = -7300352863212438745L;
+
public Serializer(TypeSerializer<?> valueSerializer, TypeSerializer<Long> timestampSerializer) {
super(true, valueSerializer, timestampSerializer);
}
@@ -143,8 +148,8 @@ public class ValueWithTs<V> implements Serializable {
@Override
protected Serializer createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) {
TypeSerializer<?> valueSerializer = nestedSerializers[0];
- TypeSerializer<Long> timeSerializer = (TypeSerializer<Long>) nestedSerializers[1];
- return new Serializer(valueSerializer, timeSerializer);
+ TypeSerializer<Long> timestampSerializer = (TypeSerializer<Long>) nestedSerializers[1];
+ return new Serializer(valueSerializer, timestampSerializer);
}
}
}