Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

more logging

This commit is contained in:
fjy 2013-12-06 09:56:23 -08:00
parent e7b6b5c2af
commit c4b990bb27
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
View File

@ -9,6 +9,7 @@ import io.druid.segment.IndexGranularity;
import io.druid.segment.realtime.FireDepartmentMetrics; import io.druid.segment.realtime.FireDepartmentMetrics;
import io.druid.segment.realtime.Schema; import io.druid.segment.realtime.Schema;
import io.druid.server.coordination.DataSegmentAnnouncer; import io.druid.server.coordination.DataSegmentAnnouncer;
import org.joda.time.DateTime;
import org.joda.time.Duration; import org.joda.time.Duration;
import org.joda.time.Period; import org.joda.time.Period;
@ -83,6 +84,8 @@ public class FlushingPlumber extends RealtimePlumber
protected void flushAfterDuration(final long truncatedTime, final Sink sink) protected void flushAfterDuration(final long truncatedTime, final Sink sink)
{ {
log.info("Abandoning segment at %s", new DateTime().plusMillis(flushDuration.toPeriod().getMillis()));
ScheduledExecutors.scheduleWithFixedDelay( ScheduledExecutors.scheduleWithFixedDelay(
flushScheduledExec, flushScheduledExec,
flushDuration, flushDuration,