[apex-core] branch master updated: APEXCORE-737 Increment numRequestedContainers instead of decrementing for an already allocated container

[vr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

vrozov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/apex-core.git


The following commit(s) were added to refs/heads/master by this push:
     new 70fa21c  APEXCORE-737 Increment numRequestedContainers instead of decrementing for an already allocated container
70fa21c is described below

commit 70fa21c9a66d50b1b4d10a5845f7f67aebbb7bd6
Author: Sanjay Pujare <sa...@users.noreply.github.com>
AuthorDate: Thu Jun 1 21:57:24 2017 -0700

    APEXCORE-737 Increment numRequestedContainers instead of decrementing for an already allocated container
---
 .../src/main/java/com/datatorrent/stram/StreamingAppMasterService.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java b/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java
index fb39d6c..61a31bd 100644
--- a/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java
+++ b/engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java
@@ -907,7 +907,7 @@ public class StreamingAppMasterService extends CompositeService
             LOG.info("Releasing {} as resource with priority {} was already assigned", allocatedContainer.getId(), allocatedContainer.getPriority());
             releasedContainers.add(allocatedContainer.getId());
             numReleasedContainers++;
-            numRequestedContainers--;
+            numRequestedContainers++;    // undo the decrement above for this allocated container
             continue;
           }
           if (csr != null) {

-- 
To stop receiving notification emails like this one, please contact
['"commits@apex.apache.org" <co...@apex.apache.org>'].