add more logging

4f0f198a · fjy · c36ffd1e · 4f0f198a
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

server/src/main/java/io/druid/segment/realtime/plumber/RealtimePlumber.java ...va/io/druid/segment/realtime/plumber/RealtimePlumber.java +4 -0

未找到文件。
--- 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;