From 4f0f198a008dfa6b5cc5559d991a00ab5f635f5e Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Thu, 14 Aug 2014 14:43:54 -0700
Subject: [PATCH] add more logging

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

diff --git a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
index 6a9aabe35be..6ad97b08ccb 100644
--- a/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
+++ b/server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java
@@ -319,6 +319,10 @@ public class RealtimePlumber implements Plumber
 
             if (!isPushedMarker.exists()) {
               removeSegment(sink, mergedTarget);
+              if (mergedTarget.exists()) {
+                log.wtf("Merged target[%s] exists?!", mergedTarget);
+                return;
+              }
             } else {
               log.info("Already pushed sink[%s]", sink);
               return;