Github user haohui commented on a diff in the pull request:
https://github.com/apache/flink/pull/4784#discussion_r143363755
--- Diff: 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) {
--- End diff --
why?---
