this.logBaseDir = logBaseDir;
this.schema = schema;
this.syncIntervalBytes = syncIntervalBytes;
this.fileMap = Maps.newHashMap();
this.maxFileSize = maxFileSize;
<BUG>this.inactiveIntervalMs = inactiveIntervalMs;
this.impersonator = impersonator;</BUG>
}
public void append(List<? extends LogWriteEvent> events) throws Exception {
if (events.isEmpty()) {

this.logBaseDir = logBaseDir;
this.schema = schema;
this.syncIntervalBytes = syncIntervalBytes;
this.fileMap = Maps.newHashMap();
this.maxFileSize = maxFileSize;
this.maxFileLifetimeMs = maxFileLifetimeMs;
this.impersonator = impersonator;
}
public void append(List<? extends LogWriteEvent> events) throws Exception {
if (events.isEmpty()) {
