[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 <[email protected]> Authored: Thu Jan 12 18:39:56 2017 +0100 Committer: Aljoscha Krettek <[email protected]> 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); } }
