diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java index 566bbe949e62b..0edb211da9f60 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java @@ -975,8 +975,14 @@ void markFailed( Map> userAccumulators, IOMetrics metrics, boolean releasePartitions, - boolean fromSchedulerNg) { - processFail(t, cancelTask, userAccumulators, metrics, releasePartitions, fromSchedulerNg); + boolean fromWithinExecutionGraph) { + processFail( + t, + cancelTask, + userAccumulators, + metrics, + releasePartitions, + fromWithinExecutionGraph); } @VisibleForTesting @@ -1148,8 +1154,8 @@ private void processFail(Throwable t, boolean cancelTask) { * @param metrics IO metrics * @param releasePartitions Indicating whether to release result partitions produced by this * execution. False if the task is FAILED in TaskManager, otherwise true. - * @param fromSchedulerNg Indicating whether the failure is from the SchedulerNg. It should be - * false if it is from within the ExecutionGraph. + * @param fromWithinExecutionGraph Indicating whether the failure is from within the + * ExecutionGraph. It should be true if it is from within the ExecutionGraph. */ private void processFail( Throwable t, @@ -1157,7 +1163,7 @@ private void processFail( Map> userAccumulators, IOMetrics metrics, boolean releasePartitions, - boolean fromSchedulerNg) { + boolean fromWithinExecutionGraph) { assertRunningInJobMasterMainThread(); @@ -1185,7 +1191,7 @@ private void processFail( return; } - if (!fromSchedulerNg) { + if (!fromWithinExecutionGraph) { vertex.getExecutionGraphAccessor() .notifySchedulerNgAboutInternalTaskFailure( attemptId, t, cancelTask, releasePartitions);