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

minor update to zk comments to make it more clear what is happening

This commit is contained in:
fjy 2015-03-23 11:47:43 -07:00
parent b389cfe404
commit a0ce1caaf8
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/src/main/java/io/druid/server/coordination/BaseZkCoordinator.java
View File

@ -119,7 +119,7 @@ public abstract class BaseZkCoordinator implements DataSegmentChangeHandler
child.getData(), DataSegmentChangeRequest.class child.getData(), DataSegmentChangeRequest.class
); );
log.info("New request[%s] with node[%s].", request.asString(), path); log.info("New request[%s] with zNode[%s].", request.asString(), path);
try { try {
request.go( request.go(
@ -143,9 +143,9 @@ public abstract class BaseZkCoordinator implements DataSegmentChangeHandler
curator.delete().guaranteed().forPath(path); curator.delete().guaranteed().forPath(path);
} }
catch (Exception e1) { catch (Exception e1) {
log.error(e1, "Failed to delete node[%s], but ignoring exception.", path); log.error(e1, "Failed to delete zNode[%s], but ignoring exception.", path);
} }
log.error(e, "Exception while removing node[%s]", path); log.error(e, "Exception while removing zNode[%s]", path);
throw Throwables.propagate(e); throw Throwables.propagate(e);
} }
} }
@ -157,7 +157,7 @@ public abstract class BaseZkCoordinator implements DataSegmentChangeHandler
curator.delete().guaranteed().forPath(path); curator.delete().guaranteed().forPath(path);
} }
catch (Exception e1) { catch (Exception e1) {
log.error(e1, "Failed to delete node[%s], but ignoring exception.", path); log.error(e1, "Failed to delete zNode[%s], but ignoring exception.", path);
} }
log.makeAlert(e, "Segment load/unload: uncaught exception.") log.makeAlert(e, "Segment load/unload: uncaught exception.")
@ -168,7 +168,7 @@ public abstract class BaseZkCoordinator implements DataSegmentChangeHandler
break; break;
case CHILD_REMOVED: case CHILD_REMOVED:
log.info("Node[%s] was removed", event.getData().getPath()); log.info("zNode[%s] was removed", event.getData().getPath());
break; break;
default: default:
log.info("Ignoring event[%s]", event); log.info("Ignoring event[%s]", event);