Skip to content

Commit 03c311e

Browse files
committed
YARN-7513. Remove the scheduler lock in FSAppAttempt.getWeight() (Contributed by Wilfred Spiegelenburg)
1 parent 67bbbe1 commit 03c311e

1 file changed

Lines changed: 4 additions & 10 deletions

File tree

  • hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/FSAppAttempt.java

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1304,20 +1304,14 @@ public Resource getResourceUsage() {
13041304

13051305
@Override
13061306
public float getWeight() {
1307-
double weight = 1.0;
1307+
float weight = 1.0F;
13081308

13091309
if (scheduler.isSizeBasedWeight()) {
1310-
scheduler.getSchedulerReadLock().lock();
1311-
1312-
try {
1313-
// Set weight based on current memory demand
1314-
weight = Math.log1p(getDemand().getMemorySize()) / Math.log(2);
1315-
} finally {
1316-
scheduler.getSchedulerReadLock().unlock();
1317-
}
1310+
// Set weight based on current memory demand
1311+
weight = (float)(Math.log1p(demand.getMemorySize()) / Math.log(2));
13181312
}
13191313

1320-
return (float)weight * this.getPriority().getPriority();
1314+
return weight * appPriority.getPriority();
13211315
}
13221316

13231317
@Override

0 commit comments

Comments
 (0)