From 932d6880220e29f45c7a69a0162cceec72e23a85 Mon Sep 17 00:00:00 2001 From: fjy Date: Fri, 6 Dec 2013 10:15:18 -0800 Subject: [PATCH] remove unneccessary merge n persist start --- .../java/io/druid/segment/realtime/plumber/FlushingPlumber.java | 1 - 1 file changed, 1 deletion(-) 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 a369deaa3b9..68aa23577ff 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 @@ -79,7 +79,6 @@ public class FlushingPlumber extends RealtimePlumber computeBaseDir(getSchema()).mkdirs(); initializeExecutors(); bootstrapSinksFromDisk(); - startPersistThread(); } protected void flushAfterDuration(final long truncatedTime, final Sink sink)