[hotfix] Adjust TaskExecutionState construction

apache · Feb 26, 2021 · cf3f5f1 · cf3f5f1
1 parent a13b0c5
commit cf3f5f1
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkUtils.java b/src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkUtils.java
@@ -149,7 +149,6 @@ public static void transitionTaskStatus(
 			executionGraph.updateState(
 					new TaskExecutionStateTransition(
 							new TaskExecutionState(
-									executionGraph.getJobID(),
 									vertex.getCurrentExecutionAttempt().getAttemptId(),
 									state)));
 		}
@@ -166,7 +165,6 @@ public static void transitionTaskStatus(
 				.getAttemptId();
 		scheduler.updateTaskExecutionState(
 				new TaskExecutionState(
-						scheduler.getExecutionGraph().getJobID(),
 						attemptId,
 						executionState));
 	}