big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-7137. MRAppBenchmark.benchmark1() fails with NullPointerException. Contributed by Oleksandr Shevchenko

Browse Source
This commit is contained in:
Jason Lowe 2018-09-18 16:56:31 -05:00
parent 5c2ae7e493
commit 34b2237e42
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/MRAppBenchmark.java
View File

@ -47,6 +47,7 @@
import org.apache.hadoop.yarn.api.records.Container; import org.apache.hadoop.yarn.api.records.Container;
import org.apache.hadoop.yarn.api.records.ContainerId; import org.apache.hadoop.yarn.api.records.ContainerId;
import org.apache.hadoop.yarn.api.records.NodeId; 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.Resource;
import org.apache.hadoop.yarn.api.records.ResourceRequest; import org.apache.hadoop.yarn.api.records.ResourceRequest;
import org.apache.hadoop.yarn.exceptions.YarnRuntimeException; import org.apache.hadoop.yarn.exceptions.YarnRuntimeException;
@ -184,7 +185,7 @@ protected void serviceStop() throws Exception {
} }
} }
@Test @Test(timeout = 60000)
public void benchmark1() throws Exception { public void benchmark1() throws Exception {
int maps = 100; // Adjust for benchmarking. Start with thousands. int maps = 100; // Adjust for benchmarking. Start with thousands.
int reduces = 0; int reduces = 0;
@ -211,6 +212,7 @@ protected ApplicationMasterProtocol createSchedulerProxy() {
Records.newRecord(RegisterApplicationMasterResponse.class); Records.newRecord(RegisterApplicationMasterResponse.class);
response.setMaximumResourceCapability(Resource.newInstance( response.setMaximumResourceCapability(Resource.newInstance(
10240, 1)); 10240, 1));
response.setQueue("queue1");
return response; return response;
} }
@ -252,6 +254,7 @@ public AllocateResponse allocate(AllocateRequest request)
response.setAllocatedContainers(containers); response.setAllocatedContainers(containers);
response.setResponseId(request.getResponseId() + 1); response.setResponseId(request.getResponseId() + 1);
response.setNumClusterNodes(350); response.setNumClusterNodes(350);
response.setApplicationPriority(Priority.newInstance(100));
return response; return response;
} }
}; };