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

more logs

This commit is contained in:
fjy 2013-12-06 09:56:47 -08:00
parent c4b990bb27
commit 986223a49d
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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,