[hotfix] Remove deprecated method in HeapKeyedStateBackend

The method is not needed and was left there by mistake.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2215f825
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2215f825
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2215f825

Branch: refs/heads/release-1.2
Commit: 2215f8252112011ddc8856fad314a4fdaacdcf8b
Parents: af244aa
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Authored: Thu Jan 12 18:39:56 2017 +0100
Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Committed: Fri Jan 13 11:38:44 2017 +0100

----------------------------------------------------------------------
 .../flink/runtime/state/heap/HeapKeyedStateBackend.java | 12 +-----------
 1 file changed, 1 insertion(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/2215f825/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
----------------------------------------------------------------------
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
index d461dfd..9a9178a 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
@@ -19,7 +19,6 @@
 package org.apache.flink.runtime.state.heap;
 
 import org.apache.commons.io.IOUtils;
-import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.state.FoldingState;
 import org.apache.flink.api.common.state.FoldingStateDescriptor;
 import org.apache.flink.api.common.state.ListState;
@@ -378,15 +377,6 @@ public class HeapKeyedStateBackend<K> extends 
AbstractKeyedStateBackend<K> {
                return "HeapKeyedStateBackend";
        }
 
-       /**
-        * REMOVE
-        */
-       @Internal
-       @Deprecated
-       public Map<String, StateTable<K, ?, ?>> getStateTables() {
-               return stateTables;
-       }
-
        @Deprecated
        private void restoreOldSavepointKeyedState(
                        Collection<KeyGroupsStateHandle> stateHandles) throws 
IOException, ClassNotFoundException {
@@ -449,7 +439,7 @@ public class HeapKeyedStateBackend<K> extends 
AbstractKeyedStateBackend<K> {
                        stateTable.getState().set(0, rawResultMap);
 
                        // add named state to the backend
-                       
getStateTables().put(registeredBackendStateMetaInfo.getName(), stateTable);
+                       
stateTables.put(registeredBackendStateMetaInfo.getName(), stateTable);
                }
        }
 

Reply via email to