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/02/20 11:09:29 UTC
[flink] 04/04: [hotfix] [core] GenericArraySerializerSnapshot
should implement isOuterSnapshotCompatible
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 337e16782b983e4bd203f670362825d2a0bebe0f
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Wed Feb 20 17:23:44 2019 +0800
[hotfix] [core] GenericArraySerializerSnapshot should implement isOuterSnapshotCompatible
---
.../api/common/typeutils/base/GenericArraySerializerSnapshot.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializerSnapshot.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializerSnapshot.java
index d39b58e..bb99ed5 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializerSnapshot.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializerSnapshot.java
@@ -77,6 +77,11 @@ public final class GenericArraySerializerSnapshot<C> extends CompositeTypeSerial
}
@Override
+ protected boolean isOuterSnapshotCompatible(GenericArraySerializer newSerializer) {
+ return this.componentClass == newSerializer.getComponentClass();
+ }
+
+ @Override
protected GenericArraySerializer createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) {
@SuppressWarnings("unchecked")
TypeSerializer<C> componentSerializer = (TypeSerializer<C>) nestedSerializers[0];