This is an automated email from the ASF dual-hosted git repository.
hexiaoqiao pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 70c0aa342e6 YARN-11482. Fix bug of DRF comparision
DominantResourceFairnessComparator2 in fair scheduler. (#5607). Contributed by
Xiaoqiao He.
70c0aa342e6 is described below
commit 70c0aa342e6a6a12b647bbfe30bb73313958e450
Author: Hexiaoqiao <hexiaoq...@apache.org>
AuthorDate: Sat Apr 29 11:18:42 2023 +0800
YARN-11482. Fix bug of DRF comparision DominantResourceFairnessComparator2
in fair scheduler. (#5607). Contributed by Xiaoqiao He.
Reviewed-by: Shilun Fan <slfan1...@apache.org>
---
.../scheduler/fair/policies/DominantResourceFairnessPolicy.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/policies/DominantResourceFairnessPolicy.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/policies/DominantResourceFairnessPolicy.java
index d234d60c6a3..e30a7cb2ea2 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/policies/DominantResourceFairnessPolicy.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/policies/DominantResourceFairnessPolicy.java
@@ -390,7 +390,7 @@ public class DominantResourceFairnessPolicy extends
SchedulingPolicy {
// share for that resource
boolean s1Needy = resourceInfo1[dominant1].getValue() <
minShareInfo1[dominant1].getValue();
- boolean s2Needy = resourceInfo1[dominant2].getValue() <
+ boolean s2Needy = resourceInfo2[dominant2].getValue() <
minShareInfo2[dominant2].getValue();
int res;
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
