Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-7211. AMSimulator in SLS does't work due to responseId refactoring.(Contributed by Botong Huang via Yufei Gu) 

(cherry picked from commit 79e37dc6db)
This commit is contained in:
Yufei Gu 2017-10-03 15:08:29 -07:00
parent b658ae002f
commit f982ffe336
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/AMSimulator.java
View File

@ -83,7 +83,7 @@ public abstract class AMSimulator extends TaskRunner.Task {
RecordFactoryProvider.getRecordFactory(null); RecordFactoryProvider.getRecordFactory(null);
// response queue // response queue
protected final BlockingQueue<AllocateResponse> responseQueue; protected final BlockingQueue<AllocateResponse> responseQueue;
protected int RESPONSE_ID = 1; private int responseId = 0;
// user name // user name
protected String user; protected String user;
// queue name // queue name
@ -274,7 +274,7 @@ public abstract class AMSimulator extends TaskRunner.Task {
List<ContainerId> toRelease) { List<ContainerId> toRelease) {
AllocateRequest allocateRequest = AllocateRequest allocateRequest =
recordFactory.newRecordInstance(AllocateRequest.class); recordFactory.newRecordInstance(AllocateRequest.class);
allocateRequest.setResponseId(RESPONSE_ID ++); allocateRequest.setResponseId(responseId++);
allocateRequest.setAskList(ask); allocateRequest.setAskList(ask);
allocateRequest.setReleaseList(toRelease); allocateRequest.setReleaseList(toRelease);
return allocateRequest; return allocateRequest;