diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/AMSimulator.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/AMSimulator.java index c69805e5b99..41219289ae9 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/AMSimulator.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/AMSimulator.java @@ -83,7 +83,7 @@ RecordFactoryProvider.getRecordFactory(null); // response queue protected final BlockingQueue responseQueue; - protected int RESPONSE_ID = 1; + protected int RESPONSE_ID = 0; // user name protected String user; // queue name @@ -274,7 +274,7 @@ protected AllocateRequest createAllocateRequest(List ask, List toRelease) { AllocateRequest allocateRequest = recordFactory.newRecordInstance(AllocateRequest.class); - allocateRequest.setResponseId(RESPONSE_ID ++); + allocateRequest.setResponseId(RESPONSE_ID); allocateRequest.setAskList(ask); allocateRequest.setReleaseList(toRelease); return allocateRequest; diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/MRAMSimulator.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/MRAMSimulator.java index 21bf05402b0..6e820ebc3b6 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/MRAMSimulator.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/MRAMSimulator.java @@ -344,6 +344,7 @@ public AllocateResponse run() throws Exception { } }); if (response != null) { + RESPONSE_ID = response.getResponseId(); responseQueue.put(response); } }