From c36ffd1e553d1abbf1464acd61c8c467c48bc7e8 Mon Sep 17 00:00:00 2001 From: fjy Date: Thu, 14 Aug 2014 14:39:08 -0700 Subject: [PATCH] address cr --- .../io/druid/segment/realtime/plumber/RealtimePlumber.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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 82ebf9f5d3e..6a9aabe35be 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 @@ -59,7 +59,6 @@ import javax.annotation.Nullable; import java.io.File; import java.io.FilenameFilter; import java.io.IOException; -import java.nio.file.Files; import java.util.Arrays; import java.util.Comparator; import java.util.List; @@ -321,7 +320,7 @@ public class RealtimePlumber implements Plumber if (!isPushedMarker.exists()) { removeSegment(sink, mergedTarget); } else { - log.info("Skipping already-merged sink: %s", sink); + log.info("Already pushed sink[%s]", sink); return; } @@ -360,7 +359,9 @@ public class RealtimePlumber implements Plumber segmentPublisher.publishSegment(segment); if (!isPushedMarker.createNewFile()) { - log.makeAlert("Unable to make marker file! WTF?!") + log.makeAlert("Failed to create marker file for [%s]", schema.getDataSource()) + .addData("interval", sink.getInterval()) + .addData("partitionNum", segment.getShardSpec().getPartitionNum()) .addData("marker", isPushedMarker) .emit(); }