[hotfix] Remove unused method in AbstractKeyedStateBackend

kaywa · Mar 20, 2019 · b5c5499 · b5c5499
1 parent 284e448
commit b5c5499
Showing 1 changed file with 0 additions and 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
@@ -23,8 +23,6 @@
 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 TypeSerializer<K> getKeySerializer() {
 		return keySerializerProvider.currentSchemaSerializer();
 	}
 
-	public TypeSerializerSchemaCompatibility<K> checkKeySerializerSchemaCompatibility(
-			TypeSerializerSnapshot<K> previousKeySerializerSnapshot) {
-
-		return keySerializerProvider.setPreviousSerializerSnapshotForRestoredState(previousKeySerializerSnapshot);
-	}
-
 	/**
 	 * @see KeyedStateBackend
 	 */