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

additional logs

This commit is contained in:
Fangjin Yang 2013-03-01 19:44:14 -08:00
parent e0700bb161
commit 1995039fb9
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -53,10 +53,8 @@ import java.util.Map;
import java.util.Set; import java.util.Set;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -407,11 +405,11 @@ public class RemoteTaskRunner implements TaskRunner
@Override @Override
public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception public void childEvent(CuratorFramework client, PathChildrenCacheEvent event) throws Exception
{ {
try { log.info("Event: %s", event.getType());
if (event.getData() != null) { if (event.getData() != null) {
log.info("Event[%s]: %s", event.getType(), event.getData().getPath()); log.info("Data: %s", event.getData().getPath());
} }
try {
if (event.getType().equals(PathChildrenCacheEvent.Type.CHILD_ADDED) || if (event.getType().equals(PathChildrenCacheEvent.Type.CHILD_ADDED) ||
event.getType().equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)) { event.getType().equals(PathChildrenCacheEvent.Type.CHILD_UPDATED)) {
@ -474,12 +472,13 @@ public class RemoteTaskRunner implements TaskRunner
cleanup(worker.getHost(), taskId); cleanup(worker.getHost(), taskId);
runPendingTasks(); runPendingTasks();
} }
} else if (event.getType().equals(PathChildrenCacheEvent.Type.CHILD_REMOVED) } else if (event.getType().equals(PathChildrenCacheEvent.Type.CHILD_REMOVED)) {
|| event.getType().equals(PathChildrenCacheEvent.Type.CONNECTION_LOST)) {
final String taskId = ZKPaths.getNodeFromPath(event.getData().getPath()); final String taskId = ZKPaths.getNodeFromPath(event.getData().getPath());
if (runningTasks.containsKey(taskId)) { if (runningTasks.containsKey(taskId)) {
log.info("Task %s just disappeared!", taskId); log.info("Task %s just disappeared!", taskId);
retryTask(runningTasks.get(taskId), worker.getHost()); retryTask(runningTasks.get(taskId), worker.getHost());
} else {
log.info("Lost a task I didn't know about: %s", taskId);
} }
} }
} }