[FLINK-7742] [java api] [runtime] Fix array index out of bounds excep…

…tions This closes apache#4754
InfinitiesLoop · Oct 6, 2017 · edc53a7 · edc53a7
1 parent 3581a33
commit edc53a7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/Utils.java b/flink-java/src/main/java/org/apache/flink/api/java/Utils.java
@@ -53,7 +53,7 @@ public static String getCallLocationName() {
  public static String getCallLocationName(int depth) {
  StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();
 
- if (stackTrace.length < depth) {
+ if (stackTrace.length <= depth) {
  return "<unknown>";
  }
 

diff --git a/.../src/main/java/org/apache/flink/runtime/query/netty/message/KvStateRequestSerializer.java b/.../src/main/java/org/apache/flink/runtime/query/netty/message/KvStateRequestSerializer.java
@@ -224,7 +224,7 @@ public static KvStateRequestType deserializeHeader(ByteBuf buf) {
  // Get the message type
  int msgType = buf.readInt();
  KvStateRequestType[] values = KvStateRequestType.values();
- if (msgType >= 0 && msgType <= values.length) {
+ if (msgType >= 0 && msgType < values.length) {
  return values[msgType];
  } else {
  throw new IllegalArgumentException("Illegal message type with index " + msgType);