commit e21978603a607c9e8e1bcacb9d5aee304b9a32ad
author Fangjin Yang <fangjin@metamarketsgroup.com> Fri Mar 01 19:03:29 2013 -0800
committer Fangjin Yang <fangjin@metamarketsgroup.com> Fri Mar 01 19:03:29 2013 -0800
tree 2c4ff6bcf7cd231965228482608adfbf8bcd25c2
parent df532f021a04c374fb972e1e82e0ee45c73437ef
parent 665d1723c0a7a45e045a6a28ec1664dca67c747e

Merge branch 'master' of github.com:metamx/druid

merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java

diff --git a/merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java b/merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
index 21b43d7..9c36eec 100644
--- a/merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
+++ b/merger/src/main/java/com/metamx/druid/merger/coordinator/RemoteTaskRunner.java
@@ -472,6 +472,7 @@
                     runPendingTasks();
                   }
                 } else if (event.getType().equals(PathChildrenCacheEvent.Type.CHILD_REMOVED)) {
+                  log.info("Event[%s]: %s", event.getType(), event.getData().getPath());
                   final String taskId = ZKPaths.getNodeFromPath(event.getData().getPath());
                   if (runningTasks.containsKey(taskId)) {
                     log.info("Task %s just disappeared!", taskId);