From 96b19356b63be388ee4ce1e789e4cb9011f4b5a2 Mon Sep 17 00:00:00 2001
From: zhangxin10 <curtain.xin@gmail.com>
Date: Thu, 12 Nov 2015 16:09:55 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BF=9D=E5=AD=98=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6=E6=A8=A1=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../skywalking/reciever/buffer/DataBufferThread.java      | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 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
index 07ecf1187..3248a1456 100644
--- 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();
             }