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 <s.rich...@data-artisans.com>
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<K>
implements
return keySerializerProvider.currentSchemaSerializer();
}
- public TypeSerializerSchemaCompatibility<K>
checkKeySerializerSchemaCompatibility(
- TypeSerializerSnapshot<K>
previousKeySerializerSnapshot) {
-
- return
keySerializerProvider.setPreviousSerializerSnapshotForRestoredState(previousKeySerializerSnapshot);
- }
-
/**
* @see KeyedStateBackend
*/
