You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ju...@apache.org on 2025/02/20 04:00:10 UTC
(flink) branch master updated: [hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method
This is an automated email from the ASF dual-hosted git repository.
junrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new cea55eb4954 [hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method
cea55eb4954 is described below
commit cea55eb4954a4a72a83904b83b325f01ee43d72c
Author: Roc Marshal <fl...@126.com>
AuthorDate: Wed Feb 19 11:53:15 2025 +0800
[hotfix][runtime] Remove the unused SchedulerBase#transitionToScheduled method
---
.../java/org/apache/flink/runtime/scheduler/SchedulerBase.java | 8 --------
1 file changed, 8 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
index 6c8914f65a1..837b5ee59f5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
@@ -549,14 +549,6 @@ public abstract class SchedulerBase implements SchedulerNG, CheckpointScheduling
return result;
}
- protected void transitionToScheduled(final List<ExecutionVertexID> verticesToDeploy) {
- verticesToDeploy.forEach(
- executionVertexId ->
- getExecutionVertex(executionVertexId)
- .getCurrentExecutionAttempt()
- .transitionState(ExecutionState.SCHEDULED));
- }
-
protected void setGlobalFailureCause(@Nullable final Throwable cause, long timestamp) {
if (cause != null) {
executionGraph.initFailureCause(cause, timestamp);