[flink] 11/32: [FLINK-11741] [runtime] WritableSerializer's ensureCompatibility method should have been removed

[tzulitai]

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 852f87638af54536cb6dfed190a250aca0ebb12f
Author: Tzu-Li (Gordon) Tai <tzuli...@apache.org>
AuthorDate: Mon Feb 25 16:18:25 2019 +0800

    [FLINK-11741] [runtime] WritableSerializer's ensureCompatibility method 
should have been removed
---
 .../api/java/typeutils/runtime/WritableSerializer.java   | 16 ++--------------
 1 file changed, 2 insertions(+), 14 deletions(-)

diff --git 
a/flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java
 
b/flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java
index 4f7b13e..3079312 100644
--- 
a/flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java
+++ 
b/flink-connectors/flink-hadoop-compatibility/src/main/java/org/apache/flink/api/java/typeutils/runtime/WritableSerializer.java
@@ -19,11 +19,9 @@
 package org.apache.flink.api.java.typeutils.runtime;
 
 import org.apache.flink.annotation.Internal;
-import org.apache.flink.api.common.typeutils.CompatibilityResult;
 import 
org.apache.flink.api.common.typeutils.GenericTypeSerializerConfigSnapshot;
 import org.apache.flink.api.common.typeutils.GenericTypeSerializerSnapshot;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
-import org.apache.flink.api.common.typeutils.TypeSerializerConfigSnapshot;
 import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility;
 import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot;
 import org.apache.flink.core.memory.DataInputView;
@@ -164,20 +162,10 @@ public final class WritableSerializer<T extends Writable> 
extends TypeSerializer
                return new WritableSerializerSnapshot<>(typeClass);
        }
 
-       @Override
-       public CompatibilityResult<T> 
ensureCompatibility(TypeSerializerConfigSnapshot<?> configSnapshot) {
-               if (configSnapshot instanceof WritableSerializerConfigSnapshot
-                               && 
typeClass.equals(((WritableSerializerConfigSnapshot<?>) 
configSnapshot).getTypeClass())) {
-
-                       return CompatibilityResult.compatible();
-               } else {
-                       return CompatibilityResult.requiresMigration();
-               }
-       }
-
        /**
         * The config snapshot for this serializer.
-        * @param <T>
+        * @deprecated This class is no longer used as a snapshot for any 
serializer.
+        *             It is fully replaced by {@link 
WritableSerializerSnapshot}.
         */
        @Deprecated
        public static final class WritableSerializerConfigSnapshot<T extends 
Writable>