[FLINK-7369] [backend] Add more information for 'Key group index out …

…of range of key group range' exception
holmes07 · Aug 4, 2017 · 0477753 · 0477753
1 parent 875a136
commit 0477753
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -101,8 +101,8 @@ private void setMapForKeyGroup(int keyGroupId, Map<N, Map<K, S>> map) {
 		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) + ").");
 		}
 	}