[flink] 03/03: [hotfix] Remove unused method in AbstractKeyedStateBackend
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git commit 2ab4ae7e862f98cffe9be187292cea7c6ed2e05c Author: Stefan Richter AuthorDate: Wed Mar 20 12:35:04 2019 +0100 [hotfix] Remove unused method in AbstractKeyedStateBackend (cherry picked from commit b5c5499789f4e2ab21c4a05bf3da8ce7408b9663) --- .../org/apache/flink/runtime/state/AbstractKeyedStateBackend.java | 8 1 file changed, 8 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java index 062092e..ab4cbf7 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java @@ -23,8 +23,6 @@ import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.api.common.state.State; import org.apache.flink.api.common.state.StateDescriptor; import org.apache.flink.api.common.typeutils.TypeSerializer; -import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility; -import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot; import org.apache.flink.core.fs.CloseableRegistry; import org.apache.flink.runtime.checkpoint.CheckpointOptions; import org.apache.flink.runtime.query.TaskKvStateRegistry; @@ -206,12 +204,6 @@ public abstract class AbstractKeyedStateBackend implements return keySerializerProvider.currentSchemaSerializer(); } - public TypeSerializerSchemaCompatibility checkKeySerializerSchemaCompatibility( - TypeSerializerSnapshot previousKeySerializerSnapshot) { - - return keySerializerProvider.setPreviousSerializerSnapshotForRestoredState(previousKeySerializerSnapshot); - } - /** * @see KeyedStateBackend */
[flink] 03/03: [hotfix] Remove unused method in AbstractKeyedStateBackend
This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit b5c5499789f4e2ab21c4a05bf3da8ce7408b9663 Author: Stefan Richter AuthorDate: Wed Mar 20 12:35:04 2019 +0100 [hotfix] Remove unused method in AbstractKeyedStateBackend --- .../org/apache/flink/runtime/state/AbstractKeyedStateBackend.java | 8 1 file changed, 8 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java index 062092e..ab4cbf7 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java @@ -23,8 +23,6 @@ import org.apache.flink.api.common.ExecutionConfig; import org.apache.flink.api.common.state.State; import org.apache.flink.api.common.state.StateDescriptor; import org.apache.flink.api.common.typeutils.TypeSerializer; -import org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility; -import org.apache.flink.api.common.typeutils.TypeSerializerSnapshot; import org.apache.flink.core.fs.CloseableRegistry; import org.apache.flink.runtime.checkpoint.CheckpointOptions; import org.apache.flink.runtime.query.TaskKvStateRegistry; @@ -206,12 +204,6 @@ public abstract class AbstractKeyedStateBackend implements return keySerializerProvider.currentSchemaSerializer(); } - public TypeSerializerSchemaCompatibility checkKeySerializerSchemaCompatibility( - TypeSerializerSnapshot previousKeySerializerSnapshot) { - - return keySerializerProvider.setPreviousSerializerSnapshotForRestoredState(previousKeySerializerSnapshot); - } - /** * @see KeyedStateBackend */