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

fix bugs in log printing

This commit is contained in:
fjy 2014-07-29 16:14:29 -07:00
parent dc38677454
commit 1586d60ec2
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -107,7 +107,7 @@ public abstract class BaseZkCoordinator implements DataSegmentChangeHandler
child.getData(), DataSegmentChangeRequest.class child.getData(), DataSegmentChangeRequest.class
); );
log.info("New node[%s] with request[%s]", path, request.asString()); log.info("New request[%s] with node[%s].", request.asString(), path);
try { try {
request.go( request.go(
@ -122,7 +122,7 @@ public abstract class BaseZkCoordinator implements DataSegmentChangeHandler
try { try {
if (!hasRun) { if (!hasRun) {
curator.delete().guaranteed().forPath(path); curator.delete().guaranteed().forPath(path);
log.info("Completed request and deleting node[%s]", path); log.info("Completed request [%s]", request.asString());
hasRun = true; hasRun = true;
} }
} }
@ -156,7 +156,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("Node[%s] was removed", event.getData().getPath());
break; break;
default: default:
log.info("Ignoring event[%s]", event); log.info("Ignoring event[%s]", event);

2
server/src/main/java/io/druid/server/coordination/SegmentChangeRequestDrop.java
View File

@ -54,7 +54,7 @@ public class SegmentChangeRequestDrop implements DataSegmentChangeRequest
@Override @Override
public String asString() public String asString()
{ {
return String.format("load %s", segment.getIdentifier()); return String.format("DROP: %s", segment.getIdentifier());
} }
@Override @Override

2
server/src/main/java/io/druid/server/coordination/SegmentChangeRequestLoad.java
View File

@ -54,7 +54,7 @@ public class SegmentChangeRequestLoad implements DataSegmentChangeRequest
@Override @Override
public String asString() public String asString()
{ {
return String.format("drop %s", segment.getIdentifier()); return String.format("LOAD: %s", segment.getIdentifier());
} }
@Override @Override

2
server/src/main/java/io/druid/server/coordination/SegmentChangeRequestNoop.java
View File

@ -32,6 +32,6 @@ public class SegmentChangeRequestNoop implements DataSegmentChangeRequest
@Override @Override
public String asString() public String asString()
{ {
return "noop"; return "NOOP";
} }
} }