[flink] branch master updated: [hotfix][runtime] Remove unnecessary method.

[pnowojski]

This is an automated email from the ASF dual-hosted git repository.

pnowojski 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 a1473da  [hotfix][runtime] Remove unnecessary method.
a1473da is described below

commit a1473daaffbab7cf7abc974fadb634408eeb3db7
Author: zhangchaoming <zhangchaom...@360.com>
AuthorDate: Thu Dec 30 10:29:43 2021 +0800

    [hotfix][runtime] Remove unnecessary method.
---
 .../strategy/SchedulingStrategyUtils.java          | 29 ----------------------
 1 file changed, 29 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java
index 269e3cb..4af58d2 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingStrategyUtils.java
@@ -33,35 +33,6 @@ import java.util.stream.Collectors;
 /** Utils for {@link SchedulingStrategy}. */
 class SchedulingStrategyUtils {
 
-    static Set<ExecutionVertexID> getAllVertexIdsFromTopology(final 
SchedulingTopology topology) {
-        return IterableUtils.toStream(topology.getVertices())
-                .map(SchedulingExecutionVertex::getId)
-                .collect(Collectors.toSet());
-    }
-
-    static Set<SchedulingExecutionVertex> getVerticesFromIds(
-            final SchedulingTopology topology, final Set<ExecutionVertexID> 
vertexIds) {
-
-        return 
vertexIds.stream().map(topology::getVertex).collect(Collectors.toSet());
-    }
-
-    static List<ExecutionVertexDeploymentOption>
-            createExecutionVertexDeploymentOptionsInTopologicalOrder(
-                    final SchedulingTopology topology,
-                    final Set<ExecutionVertexID> verticesToDeploy,
-                    final Function<ExecutionVertexID, DeploymentOption> 
deploymentOptionRetriever) {
-
-        return IterableUtils.toStream(topology.getVertices())
-                .map(SchedulingExecutionVertex::getId)
-                .filter(verticesToDeploy::contains)
-                .map(
-                        executionVertexID ->
-                                new ExecutionVertexDeploymentOption(
-                                        executionVertexID,
-                                        
deploymentOptionRetriever.apply(executionVertexID)))
-                .collect(Collectors.toList());
-    }
-
     static List<ExecutionVertexDeploymentOption> 
createExecutionVertexDeploymentOptions(
             final Collection<ExecutionVertexID> verticesToDeploy,
             final Function<ExecutionVertexID, DeploymentOption> 
deploymentOptionRetriever) {