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/28 11:05:22 UTC
[flink] 11/32: [FLINK-11741] [runtime] WritableSerializer's
ensureCompatibility method should have been removed
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 <tz...@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>