LoggingConfiguration.DEFAULT_LOG_CLEANUP_RUN_INTERVAL_MINS);
Preconditions.checkArgument(logCleanupIntervalMins > 0,
"Log cleanup run interval is invalid: %s", logCleanupIntervalMins);
AvroFileWriter avroFileWriter = new AvroFileWriter(fileMetaDataManager, namespacedLocationFactory, logBaseDir,
serializer.getAvroSchema(), maxLogFileSizeBytes,
<BUG>syncIntervalBytes, inactiveIntervalMs, impersonator);
</BUG>
checkpointManager = checkpointManagerFactory.create(cConf.get(Constants.Logging.KAFKA_TOPIC),
CHECKPOINT_ROW_KEY_PREFIX);
this.logFileWriter = new CheckpointingLogFileWriter(avroFileWriter, checkpointManager, checkpointIntervalMs);

LoggingConfiguration.DEFAULT_LOG_CLEANUP_RUN_INTERVAL_MINS);
Preconditions.checkArgument(logCleanupIntervalMins > 0,
"Log cleanup run interval is invalid: %s", logCleanupIntervalMins);
AvroFileWriter avroFileWriter = new AvroFileWriter(fileMetaDataManager, namespacedLocationFactory, logBaseDir,
serializer.getAvroSchema(), maxLogFileSizeBytes,
syncIntervalBytes, maxFileLifetimeMs, impersonator);
checkpointManager = checkpointManagerFactory.create(cConf.get(Constants.Logging.KAFKA_TOPIC),
CHECKPOINT_ROW_KEY_PREFIX);
this.logFileWriter = new CheckpointingLogFileWriter(avroFileWriter, checkpointManager, checkpointIntervalMs);
