You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/02/26 12:47:31 UTC
[flink-benchmarks] branch master updated: [hotfix] Adjust
TaskExecutionState construction
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git
The following commit(s) were added to refs/heads/master by this push:
new cf3f5f1 [hotfix] Adjust TaskExecutionState construction
cf3f5f1 is described below
commit cf3f5f1ff344390c2de9a21c453fd74064899d1a
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Fri Feb 26 13:47:25 2021 +0100
[hotfix] Adjust TaskExecutionState construction
---
.../org/apache/flink/scheduler/benchmark/SchedulerBenchmarkUtils.java | 2 --
1 file changed, 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
index dbe448d..bba1616 100644
--- 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 class SchedulerBenchmarkUtils {
executionGraph.updateState(
new TaskExecutionStateTransition(
new TaskExecutionState(
- executionGraph.getJobID(),
vertex.getCurrentExecutionAttempt().getAttemptId(),
state)));
}
@@ -166,7 +165,6 @@ public class SchedulerBenchmarkUtils {
.getAttemptId();
scheduler.updateTaskExecutionState(
new TaskExecutionState(
- scheduler.getExecutionGraph().getJobID(),
attemptId,
executionState));
}