[flink] 01/03: [hotfix] Enforce StateTable return IterableStateSnapshot

[dwysakowicz]

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit b6c80390d7af57c5d6fd0a85ae6ab425cc098f90
Author: Dawid Wysakowicz <dwysakow...@apache.org>
AuthorDate: Fri Jan 29 10:23:26 2021 +0100

    [hotfix] Enforce StateTable return IterableStateSnapshot
---
 .../main/java/org/apache/flink/runtime/state/heap/StateTable.java    | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java
index 57d5d01..c64184d 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java
@@ -21,6 +21,7 @@ package org.apache.flink.runtime.state.heap;
 import org.apache.flink.annotation.VisibleForTesting;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.java.tuple.Tuple2;
+import org.apache.flink.runtime.state.IterableStateSnapshot;
 import org.apache.flink.runtime.state.KeyGroupRangeAssignment;
 import org.apache.flink.runtime.state.RegisteredKeyValueStateBackendMetaInfo;
 import org.apache.flink.runtime.state.StateEntry;
@@ -99,6 +100,10 @@ public abstract class StateTable<K, N, S>
 
     protected abstract StateMap<K, N, S> createStateMap();
 
+    @Override
+    @Nonnull
+    public abstract IterableStateSnapshot<K, N, S> stateSnapshot();
+
     // Main interface methods of StateTable 
-------------------------------------------------------
 
     /**