remove unneccessary merge n persist start

This commit is contained in:
fjy 2013-12-06 10:15:18 -08:00
parent 90aa9eca47
commit 932d688022

View File

@ -79,7 +79,6 @@ public class FlushingPlumber extends RealtimePlumber
computeBaseDir(getSchema()).mkdirs();
initializeExecutors();
bootstrapSinksFromDisk();
startPersistThread();
}
protected void flushAfterDuration(final long truncatedTime, final Sink sink)