You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/06/13 08:39:30 UTC
[2/2] flink git commit: [FLINK-6899] [state] Create correctly sized
state array in NestedMapsStateTable
[FLINK-6899] [state] Create correctly sized state array in NestedMapsStateTable
This closes #4107.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a1d70f57
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a1d70f57
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a1d70f57
Branch: refs/heads/release-1.3
Commit: a1d70f5730c7186dd4aa02ec5628a19d8c56f6e8
Parents: db97526
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Jun 12 15:21:47 2017 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Jun 13 10:35:58 2017 +0200
----------------------------------------------------------------------
.../org/apache/flink/runtime/state/heap/NestedMapsStateTable.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a1d70f57/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java
index 75c31db..e31e58f 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/NestedMapsStateTable.java
@@ -68,7 +68,7 @@ public class NestedMapsStateTable<K, N, S> extends StateTable<K, N, S> {
this.keyGroupOffset = keyContext.getKeyGroupRange().getStartKeyGroup();
@SuppressWarnings("unchecked")
- Map<N, Map<K, S>>[] state = (Map<N, Map<K, S>>[]) new Map[keyContext.getNumberOfKeyGroups()];
+ Map<N, Map<K, S>>[] state = (Map<N, Map<K, S>>[]) new Map[keyContext.getKeyGroupRange().getNumberOfKeyGroups()];
this.state = state;
}