From 90aa9eca478d12befc1636f6eb0fab5b9a60ec7f Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Fri, 6 Dec 2013 09:57:07 -0800
Subject: [PATCH] more logs

---
 .../java/io/druid/segment/realtime/plumber/FlushingPlumber.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 0d5ab7c3386..a369deaa3b9 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
@@ -74,7 +74,7 @@ public class FlushingPlumber extends RealtimePlumber
   @Override
   public void startJob()
   {
-    log.info("Starting job");
+    log.info("Starting job for %s", getSchema().getDataSource());
 
     computeBaseDir(getSchema()).mkdirs();
     initializeExecutors();