fix casting

2013-12-06 11:16:27 -08:00 · 2013-12-06 11:16:27 -08:00 · 5fe0a8f2fb
parent 1fcbbc8262
commit 5fe0a8f2fb
1 changed files with 1 additions and 1 deletions
--- a/server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
+++ b/server/src/main/java/io/druid/segment/realtime/plumber/FlushingPlumber.java
@ -96,7 +96,7 @@ public class FlushingPlumber extends RealtimePlumber
    log.info(
        "Abandoning segment %s at %s",
        sink.getSegment().getIdentifier(),
-        new DateTime().plusMillis(flushDuration.getMillis())
+        new DateTime().plusMillis((int) flushDuration.getMillis())
    );

    ScheduledExecutors.scheduleWithFixedDelay(