From 986223a49d3da761a2b9a449c63b6faf70f69569 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 6 Dec 2013 09:56:47 -0800 Subject: [PATCH] more logs --- .../druid/segment/realtime/plumber/FlushingPlumber.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) 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 e8d89f2fca5..0d5ab7c3386 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 @@ -84,8 +84,12 @@ 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())); - + log.info( + "Abandoning segment %s at %s", + sink.getSegment().getIdentifier(), + new DateTime().plusMillis(flushDuration.toPeriod().getMillis()) + ); + ScheduledExecutors.scheduleWithFixedDelay( flushScheduledExec, flushDuration,