This is an automated email from the ASF dual-hosted git repository. fanrui 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 ed42b094496 [FLINK-31907][coordination] Remove the unused field inside ExecutionSlotSharingGroupBuilder ed42b094496 is described below commit ed42b094496ffaa503d3add44a91fad5669c9dd7 Author: 1996fanrui <1996fan...@gmail.com> AuthorDate: Mon Apr 24 15:32:42 2023 +0800 [FLINK-31907][coordination] Remove the unused field inside ExecutionSlotSharingGroupBuilder --- .../scheduler/LocalInputPreferredSlotSharingStrategy.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java index d0b71d64df5..99b4f1ca85a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java @@ -18,7 +18,6 @@ package org.apache.flink.runtime.scheduler; -import org.apache.flink.runtime.instance.SlotSharingGroupId; import org.apache.flink.runtime.jobgraph.IntermediateResultPartitionID; import org.apache.flink.runtime.jobgraph.JobVertexID; import org.apache.flink.runtime.jobmanager.scheduler.CoLocationConstraint; @@ -133,9 +132,6 @@ class LocalInputPreferredSlotSharingStrategy private final Map<CoLocationConstraint, ExecutionSlotSharingGroup> constraintToExecutionSlotSharingGroupMap; - private final Map<SlotSharingGroupId, List<ExecutionSlotSharingGroup>> - executionSlotSharingGroups; - /** * A JobVertex only belongs to one {@link SlotSharingGroup}. A SlotSharingGroup is * corresponding to a set of {@link ExecutionSlotSharingGroup}s. We can maintain available @@ -197,7 +193,6 @@ class LocalInputPreferredSlotSharingStrategy executionSlotSharingGroupMap = new HashMap<>(); constraintToExecutionSlotSharingGroupMap = new HashMap<>(); - executionSlotSharingGroups = new HashMap<>(); availableGroupsForJobVertex = new HashMap<>(); candidateGroupsForConsumedPartitionGroup = new IdentityHashMap<>(); } @@ -398,15 +393,10 @@ class LocalInputPreferredSlotSharingStrategy ExecutionVertexID executionVertexId) { final SlotSharingGroup slotSharingGroup = getSlotSharingGroup(executionVertexId.getJobVertexId()); - final List<ExecutionSlotSharingGroup> correspondingExecutionSlotSharingGroups = - executionSlotSharingGroups.computeIfAbsent( - slotSharingGroup.getSlotSharingGroupId(), k -> new ArrayList<>()); final ExecutionSlotSharingGroup newGroup = new ExecutionSlotSharingGroup(); newGroup.setResourceProfile(slotSharingGroup.getResourceProfile()); - correspondingExecutionSlotSharingGroups.add(newGroup); - // Once a new ExecutionSlotSharingGroup is created, it's available for all JobVertices // in this SlotSharingGroup for (JobVertexID jobVertexId : slotSharingGroup.getJobVertexIds()) {