|
@@ -286,6 +286,7 @@ public class FileSystemTimelineWriter extends TimelineWriter{
|
|
mapper.setAnnotationIntrospector(new JaxbAnnotationIntrospector());
|
|
mapper.setAnnotationIntrospector(new JaxbAnnotationIntrospector());
|
|
mapper.setSerializationInclusion(Inclusion.NON_NULL);
|
|
mapper.setSerializationInclusion(Inclusion.NON_NULL);
|
|
mapper.configure(Feature.CLOSE_CLOSEABLE, false);
|
|
mapper.configure(Feature.CLOSE_CLOSEABLE, false);
|
|
|
|
+ mapper.configure(Feature.FLUSH_AFTER_WRITE_VALUE, false);
|
|
return mapper;
|
|
return mapper;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -366,6 +367,7 @@ public class FileSystemTimelineWriter extends TimelineWriter{
|
|
|
|
|
|
public void flush() throws IOException {
|
|
public void flush() throws IOException {
|
|
if (stream != null) {
|
|
if (stream != null) {
|
|
|
|
+ jsonGenerator.flush();
|
|
stream.hflush();
|
|
stream.hflush();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -378,8 +380,6 @@ public class FileSystemTimelineWriter extends TimelineWriter{
|
|
this.stream = createLogFileStream(fs, logPath);
|
|
this.stream = createLogFileStream(fs, logPath);
|
|
this.jsonGenerator = new JsonFactory().createJsonGenerator(stream);
|
|
this.jsonGenerator = new JsonFactory().createJsonGenerator(stream);
|
|
this.jsonGenerator.setPrettyPrinter(new MinimalPrettyPrinter("\n"));
|
|
this.jsonGenerator.setPrettyPrinter(new MinimalPrettyPrinter("\n"));
|
|
- this.jsonGenerator.configure(
|
|
|
|
- JsonGenerator.Feature.FLUSH_PASSED_TO_STREAM, false);
|
|
|
|
this.lastModifiedTime = Time.monotonicNow();
|
|
this.lastModifiedTime = Time.monotonicNow();
|
|
}
|
|
}
|
|
|
|
|