From f8ff9296bc4bab175379d7235b1cf53f9ea36c35 Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Fri, 6 Dec 2013 10:26:35 -0800
Subject: [PATCH] fix logs

---
 .../io/druid/segment/realtime/plumber/FlushingPlumber.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
index 9f6e4c41acc..a69d4bef4f9 100644
--- a/server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
+++ b/server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
@@ -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;