修改保存文件模式

2015-11-12 16:09:55 +08:00 · 2015-11-12 16:09:55 +08:00 · 96b19356b6
parent a4fa7c14a1
commit 96b19356b6
1 changed files with 8 additions and 0 deletions
--- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/DataBufferThread.java
+++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/DataBufferThread.java
@ -80,6 +80,14 @@ public class DataBufferThread extends Thread {

            }

+            if (bool){
+                try {
+                    outputStream.flush();
+                } catch (IOException e) {
+                    logger.error("Flush buffer data failed.", e);
+                }
+            }
+
            if (file.length() > DATA_FILE_MAX_LENGTH) {
                convertFile();
            }