You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/01/12 17:40:43 UTC
flink git commit: [hotfix] Remove deprecated method in
HeapKeyedStateBackend
Repository: flink
Updated Branches:
refs/heads/master 82ed79999 -> 46423b9c7
[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/46423b9c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/46423b9c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/46423b9c
Branch: refs/heads/master
Commit: 46423b9c7d1e49791fa077d653359a4ac3d83115
Parents: 82ed799
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Thu Jan 12 18:39:56 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Thu Jan 12 18:39:56 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/46423b9c/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);
}
}