Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

RemoteTaskRunner: Only cleanup paths during bootstrapping if task is complete

This commit is contained in:
Gian Merlino 2013-01-25 16:01:17 -08:00
parent efdff7b9f1
commit 1cff766e2a
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
View File

@ -316,7 +316,10 @@ public class RemoteTaskRunner implements TaskRunner
if (callback != null) {
callback.notify(taskStatus);
}
new CleanupPaths(worker.getHost(), taskWrapper.getTask().getId()).run();
if (taskStatus.isComplete()) {
new CleanupPaths(worker.getHost(), taskWrapper.getTask().getId()).run();
}
} else {
log.warn("Worker data was null for worker: %s", worker.getHost());
}