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();