Repository: hadoop Updated Branches: refs/heads/branch-2.9 355539717 -> 6005f0a3e
addendum patch for YARN-7289. (cherry picked from commit 940ffe3f9ce74286a8863e3743faf88a33c817a3) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/6005f0a3 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/6005f0a3 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/6005f0a3 Branch: refs/heads/branch-2.9 Commit: 6005f0a3eeba2ff01fd9a29a640377e427a73fbb Parents: 3555397 Author: Rohith Sharma K S <rohithsharm...@apache.org> Authored: Thu Nov 2 13:55:19 2017 +0530 Committer: Rohith Sharma K S <rohithsharm...@apache.org> Committed: Thu Nov 2 14:11:33 2017 +0530 ---------------------------------------------------------------------- .../scheduler/AbstractYarnScheduler.java | 4 ++-- .../scheduler/capacity/CapacityScheduler.java | 2 +- .../rmapp/TestApplicationLifetimeMonitor.java | 24 +++++++++++--------- 3 files changed, 16 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/6005f0a3/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java ---------------------------------------------------------------------- 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/AbstractYarnScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java index 5b6fdc6..3e41da7 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/AbstractYarnScheduler.java @@ -1327,8 +1327,8 @@ public abstract class AbstractYarnScheduler @Override public long checkAndGetApplicationLifetime(String queueName, long lifetime) { - // -1 indicates, lifetime is not configured. - return -1; + // Lifetime is the application lifetime by default. + return lifetime; } @Override http://git-wip-us.apache.org/repos/asf/hadoop/blob/6005f0a3/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java ---------------------------------------------------------------------- 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/capacity/CapacityScheduler.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java index 6e7b8a8..d472d35 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacityScheduler.java @@ -2592,7 +2592,7 @@ public class CapacityScheduler extends long maximumApplicationLifetime = ((LeafQueue) queue).getMaximumApplicationLifetime(); - // check only for maximum, that's enough because default cann't + // check only for maximum, that's enough because default can't // exceed maximum if (maximumApplicationLifetime <= 0) { return lifetimeRequestedByApp; http://git-wip-us.apache.org/repos/asf/hadoop/blob/6005f0a3/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/TestApplicationLifetimeMonitor.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/TestApplicationLifetimeMonitor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/TestApplicationLifetimeMonitor.java index b1da9af..037ed99 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/TestApplicationLifetimeMonitor.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/rmapp/TestApplicationLifetimeMonitor.java @@ -30,6 +30,7 @@ import java.util.HashMap; import java.util.Map; import java.util.Set; +import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest; import org.apache.hadoop.yarn.api.protocolrecords.UpdateApplicationTimeoutsRequest; @@ -72,6 +73,8 @@ import org.junit.runners.Parameterized; */ @RunWith(Parameterized.class) public class TestApplicationLifetimeMonitor { + private final long maxLifetime = 30L; + private YarnConfiguration conf; @Parameterized.Parameters @@ -90,7 +93,16 @@ public class TestApplicationLifetimeMonitor { @Before public void setup() throws IOException { - conf = new YarnConfiguration(); + if (scheduler.equals(CapacityScheduler.class)) { + // Since there is limited lifetime monitoring support in fair scheduler + // it does not need queue setup + long defaultLifetime = 15L; + Configuration capacitySchedulerConfiguration = + setUpCSQueue(maxLifetime, defaultLifetime); + conf = new YarnConfiguration(capacitySchedulerConfiguration); + } else { + conf = new YarnConfiguration(); + } // Always run for CS, since other scheduler do not support this. conf.setClass(YarnConfiguration.RM_SCHEDULER, scheduler, ResourceScheduler.class); @@ -106,16 +118,6 @@ public class TestApplicationLifetimeMonitor { throws Exception { MockRM rm = null; try { - long maxLifetime = 30L; - long defaultLifetime = 15L; - - YarnConfiguration newConf; - if (scheduler.equals(CapacityScheduler.class)) { - // Since there is limited lifetime monitoring support in fair scheduler - // it does not need queue setup - conf = - new YarnConfiguration(setUpCSQueue(maxLifetime, defaultLifetime)); - } rm = new MockRM(conf); rm.start(); --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org