src/main/java/com/uber/rss/execution/ShuffleExecutor.java [397:410]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            if (finished) {
                break;
            }

            try {
                Thread.sleep(INTERNAL_WAKEUP_MILLIS);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }

        if (!finished) {
            throw new RuntimeException("AppTaskAttemptId not finished: "
                + appTaskAttemptId);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/execution/ShuffleExecutor.java [429:442]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            if (finished) {
                break;
            }

            try {
                Thread.sleep(INTERNAL_WAKEUP_MILLIS);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }

        if (!finished) {
            throw new RuntimeException("AppTaskAttemptId not finished: "
                    + appTaskAttemptId);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -