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

fix logs

This commit is contained in:
fjy 2013-12-06 10:26:35 -08:00
parent 767663af92
commit f8ff9296bc
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
View File

@ -156,7 +156,7 @@ public class FlushingPlumber extends RealtimePlumber
for (Map.Entry<Long, Sink> entry : getSinks().entrySet()) {
final Long intervalStart = entry.getKey();
if (intervalStart < minTimestamp) {
log.info("Adding entry[%s] for merge and push.", entry);
log.info("Adding entry[%s] to flush.", entry);
sinksToPush.add(entry);
}
}
@ -166,7 +166,7 @@ public class FlushingPlumber extends RealtimePlumber
}
if (stopped) {
log.info("Stopping merge-n-push overseer thread");
log.info("Stopping flusher thread");
return ScheduledExecutors.Signal.STOP;
} else {
return ScheduledExecutors.Signal.REPEAT;