Fix #1608, Fix file mover OOM issue (#1610)

Intel-bigdata · Mar 2, 2018 · d317928 · d317928
1 parent 490df26
commit d317928
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...doop-support/smart-hadoop/src/main/java/org/smartdata/hdfs/action/move/MoverExecutor.java b/...doop-support/smart-hadoop/src/main/java/org/smartdata/hdfs/action/move/MoverExecutor.java
@@ -104,7 +104,12 @@ public int executeMove(FileMovePlan plan, PrintStream resultOs, PrintStream logO
     parseSchedulePlan(plan);
 
     moveExecutor = Executors.newFixedThreadPool(maxConcurrentMoves);
-    return doMove(resultOs, logOs);
+    try {
+      return doMove(resultOs, logOs);
+    } finally {
+      moveExecutor.shutdown();
+      moveExecutor = null;
+    }
   }
 
   /**