You are viewing a plain text version of this content. The canonical link for it is here.
Posted to yarn-commits@hadoop.apache.org by ju...@apache.org on 2014/06/05 15:15:45 UTC
svn commit: r1600644 - in /hadoop/common/trunk/hadoop-yarn-project:
CHANGES.txt
hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestClientRMService.java
Author: junping_du
Date: Thu Jun 5 13:15:44 2014
New Revision: 1600644
URL: http://svn.apache.org/r1600644
Log:
YARN-1977. Add tests on getApplicationRequest with filtering start time range. (Contributed by Junping Du)
Modified:
hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt
hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestClientRMService.java
Modified: hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt?rev=1600644&r1=1600643&r2=1600644&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt (original)
+++ hadoop/common/trunk/hadoop-yarn-project/CHANGES.txt Thu Jun 5 13:15:44 2014
@@ -137,6 +137,8 @@ Release 2.5.0 - UNRELEASED
YARN-2061. Revisit logging levels in ZKRMStateStore. (Ray Chiang via kasha)
+ YARN-1977. Add tests on getApplicationRequest with filtering start time range. (junping_du)
+
OPTIMIZATIONS
BUG FIXES
Modified: hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestClientRMService.java
URL: http://svn.apache.org/viewvc/hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestClientRMService.java?rev=1600644&r1=1600643&r2=1600644&view=diff
==============================================================================
--- hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestClientRMService.java (original)
+++ hadoop/common/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestClientRMService.java Thu Jun 5 13:15:44 2014
@@ -646,7 +646,8 @@ public class TestClientRMService {
ApplicationId[] appIds =
{getApplicationId(101), getApplicationId(102), getApplicationId(103)};
List<String> tags = Arrays.asList("Tag1", "Tag2", "Tag3");
-
+
+ long[] submitTimeMillis = new long[3];
// Submit applications
for (int i = 0; i < appIds.length; i++) {
ApplicationId appId = appIds[i];
@@ -656,6 +657,7 @@ public class TestClientRMService {
appId, appNames[i], queues[i % queues.length],
new HashSet<String>(tags.subList(0, i + 1)));
rmService.submitApplication(submitRequest);
+ submitTimeMillis[i] = System.currentTimeMillis();
}
// Test different cases of ClientRMService#getApplications()
@@ -667,6 +669,24 @@ public class TestClientRMService {
request.setLimit(1L);
assertEquals("Failed to limit applications", 1,
rmService.getApplications(request).getApplicationList().size());
+
+ // Check start range
+ request = GetApplicationsRequest.newInstance();
+ request.setStartRange(submitTimeMillis[0], System.currentTimeMillis());
+
+ // 2 applications are submitted after first timeMills
+ assertEquals("Incorrect number of matching start range",
+ 2, rmService.getApplications(request).getApplicationList().size());
+
+ // 1 application is submitted after the second timeMills
+ request.setStartRange(submitTimeMillis[1], System.currentTimeMillis());
+ assertEquals("Incorrect number of matching start range",
+ 1, rmService.getApplications(request).getApplicationList().size());
+
+ // no application is submitted after the third timeMills
+ request.setStartRange(submitTimeMillis[2], System.currentTimeMillis());
+ assertEquals("Incorrect number of matching start range",
+ 0, rmService.getApplications(request).getApplicationList().size());
// Check queue
request = GetApplicationsRequest.newInstance();