flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From srich...@apache.org
Subject flink git commit: [FLINK-7369] [backend] Add more information for 'Key group index out of range of key group range' exception
Date Fri, 04 Aug 2017 08:57:08 GMT
Repository: flink
Updated Branches:
  refs/heads/master 875a1369c -> 04777538c


[FLINK-7369] [backend] Add more information for 'Key group index out of range of key group
range' exception


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

Branch: refs/heads/master
Commit: 04777538c0a54c113d0f9b49b5922ba47f6e1eb8
Parents: 875a136
Author: Stefan Richter <s.richter@data-artisans.com>
Authored: Fri Aug 4 10:56:02 2017 +0200
Committer: Stefan Richter <s.richter@data-artisans.com>
Committed: Fri Aug 4 10:56:02 2017 +0200

----------------------------------------------------------------------
 .../apache/flink/runtime/state/heap/NestedMapsStateTable.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/04777538/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 e31e58f..02d0cd4 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
@@ -101,8 +101,8 @@ public class NestedMapsStateTable<K, N, S> extends StateTable<K,
N, S> {
 		try {
 			state[indexToOffset(keyGroupId)] = map;
 		} catch (ArrayIndexOutOfBoundsException e) {
-			throw new IllegalArgumentException("Key group index out of range of key group range ["
+
-					keyGroupOffset + ", " + (keyGroupOffset + state.length) + ").");
+			throw new IllegalArgumentException("Key group index " + keyGroupId + " is out of range
of key group " +
+				"range [" + keyGroupOffset + ", " + (keyGroupOffset + state.length) + ").");
 		}
 	}
 


Mime
View raw message