[flink] branch master updated: [FLINK-31907][coordination] Remove the unused field inside ExecutionSlotSharingGroupBuilder

[fanrui]

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()) 
{