From c4b990bb270242a29ad0c6078b33c213a5470987 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 6 Dec 2013 09:56:23 -0800 Subject: [PATCH] more logging --- .../io/druid/segment/realtime/plumber/FlushingPlumber.java | 3 +++ 1 file changed, 3 insertions(+) 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 4d8adc497fb..e8d89f2fca5 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 @@ -9,6 +9,7 @@ import io.druid.segment.IndexGranularity; import io.druid.segment.realtime.FireDepartmentMetrics; import io.druid.segment.realtime.Schema; import io.druid.server.coordination.DataSegmentAnnouncer; +import org.joda.time.DateTime; import org.joda.time.Duration; import org.joda.time.Period; @@ -83,6 +84,8 @@ public class FlushingPlumber extends RealtimePlumber protected void flushAfterDuration(final long truncatedTime, final Sink sink) { + log.info("Abandoning segment at %s", new DateTime().plusMillis(flushDuration.toPeriod().getMillis())); + ScheduledExecutors.scheduleWithFixedDelay( flushScheduledExec, flushDuration,