[flink] branch master updated: [hotfix] [runtime] Remove unused method ResourceManager#getNumberRequiredTaskManagers()

[leonard]

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

leonard 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 9055279  [hotfix] [runtime] Remove unused method 
ResourceManager#getNumberRequiredTaskManagers()
9055279 is described below

commit 9055279d0286f4374694325250a45dc1c60301a7
Author: xuzifu666 <1206332...@qq.com>
AuthorDate: Tue Mar 1 17:10:56 2022 +0800

    [hotfix] [runtime] Remove unused method 
ResourceManager#getNumberRequiredTaskManagers()
    
    This closes #18662.
---
 .../org/apache/flink/runtime/resourcemanager/ResourceManager.java     | 4 ----
 1 file changed, 4 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
index 750860d..2696976 100755
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
@@ -1410,10 +1410,6 @@ public abstract class ResourceManager<WorkerType extends 
ResourceIDRetrievable>
     //  Resource Management
     // ------------------------------------------------------------------------
 
-    protected int getNumberRequiredTaskManagers() {
-        return getRequiredResources().values().stream().reduce(0, 
Integer::sum);
-    }
-
     protected Map<WorkerResourceSpec, Integer> getRequiredResources() {
         return slotManager.getRequiredResources();
     }