From a4fa7c14a17001b1629fc7e78ff0ca28d12d99e7 Mon Sep 17 00:00:00 2001
From: zhangxin10 <curtain.xin@gmail.com>
Date: Thu, 12 Nov 2015 16:06:51 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3index?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cloud/skywalking/reciever/buffer/DataBufferThread.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 ec841e2d8..07ecf1187 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
@@ -43,11 +43,10 @@ public class DataBufferThread extends Thread {
     @Override
     public void run() {
         boolean isWriteFailure;
-        byte[] tmpByte;
+        int index = 0;
         while (true) {
             boolean bool = false;
             int count = 0;
-            int index = 0;
             for (int i = 0; i < data.length; i++, count++) {
                 if (data[i] == null) {
                     continue;
@@ -73,6 +72,8 @@ public class DataBufferThread extends Thread {
                         outputStream.flush();
                     } catch (IOException e) {
                         logger.error("Flush buffer data failed.", e);
+                    } finally {
+                        index = 0;
                     }
                 }
                 data[i] = null;