flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [4/4] flink git commit: [hotfix] Remove deprecated method in HeapKeyedStateBackend
Date Fri, 13 Jan 2017 10:45:52 GMT
[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.krettek@gmail.com>
Authored: Thu Jan 12 18:39:56 2017 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@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);
 		}
 	}
 


Mime
View raw message