|
@@ -44,6 +44,7 @@ import org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRespo
|
|
|
import org.apache.hadoop.yarn.api.records.Container;
|
|
|
import org.apache.hadoop.yarn.api.records.ContainerId;
|
|
|
import org.apache.hadoop.yarn.api.records.NodeId;
|
|
|
+import org.apache.hadoop.yarn.api.records.Priority;
|
|
|
import org.apache.hadoop.yarn.api.records.Resource;
|
|
|
import org.apache.hadoop.yarn.api.records.ResourceRequest;
|
|
|
import org.apache.hadoop.yarn.exceptions.YarnRuntimeException;
|
|
@@ -181,7 +182,7 @@ public class MRAppBenchmark {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- @Test
|
|
|
+ @Test(timeout = 60000)
|
|
|
public void benchmark1() throws Exception {
|
|
|
int maps = 100; // Adjust for benchmarking. Start with thousands.
|
|
|
int reduces = 0;
|
|
@@ -206,6 +207,7 @@ public class MRAppBenchmark {
|
|
|
Records.newRecord(RegisterApplicationMasterResponse.class);
|
|
|
response.setMaximumResourceCapability(Resource.newInstance(
|
|
|
10240, 1));
|
|
|
+ response.setQueue("queue1");
|
|
|
return response;
|
|
|
}
|
|
|
|
|
@@ -247,6 +249,7 @@ public class MRAppBenchmark {
|
|
|
response.setAllocatedContainers(containers);
|
|
|
response.setResponseId(request.getResponseId() + 1);
|
|
|
response.setNumClusterNodes(350);
|
|
|
+ response.setApplicationPriority(Priority.newInstance(100));
|
|
|
return response;
|
|
|
}
|
|
|
};
|