From 413d410a1a442cabcf148340ef02acb18dda866f Mon Sep 17 00:00:00 2001
From: "navis.ryu" <navis@apache.org>
Date: Tue, 7 Apr 2015 16:53:26 +0900
Subject: [PATCH] TAJO-1538 TajoWorkerResourceManager.allocatedResourceMap is
 increasing forever

---
 .../org/apache/tajo/master/rm/TajoWorkerResourceManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tajo-core/src/main/java/org/apache/tajo/master/rm/TajoWorkerResourceManager.java b/tajo-core/src/main/java/org/apache/tajo/master/rm/TajoWorkerResourceManager.java
index 0d830eaa34..541b1b6c81 100644
--- a/tajo-core/src/main/java/org/apache/tajo/master/rm/TajoWorkerResourceManager.java
+++ b/tajo-core/src/main/java/org/apache/tajo/master/rm/TajoWorkerResourceManager.java
@@ -508,7 +508,7 @@ private List<AllocatedWorkerResource> chooseWorkers(WorkerResourceRequest resour
    */
   @Override
   public void releaseWorkerResource(ContainerProtocol.TajoContainerIdProto containerId) {
-    AllocatedWorkerResource allocated = allocatedResourceMap.get(containerId);
+    AllocatedWorkerResource allocated = allocatedResourceMap.remove(containerId);
     if(allocated != null) {
       LOG.info("Release Resource: " + allocated.allocatedDiskSlots + "," + allocated.allocatedMemoryMB);
       allocated.worker.getResource().releaseResource( allocated.allocatedDiskSlots, allocated.allocatedMemoryMB);