diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java index 8538ac8a3..011c59444 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java @@ -16,9 +16,13 @@ public class PersistenceThread extends Thread { @Override public void run() { - int length = 0; + int length; + File file1; + BufferedReader bufferedReader; + int offset; + StringBuffer data; while (true) { - File file1 = getDataFiles(); + file1 = getDataFiles(); if (file1 == null) { try { Thread.sleep(SWITCH_FILE_WAIT_TIME); @@ -29,13 +33,13 @@ public class PersistenceThread extends Thread { } try { - BufferedReader bufferedReader = new BufferedReader(new FileReader(file1)); - int offset = moveOffSet(file1, bufferedReader); + bufferedReader = new BufferedReader(new FileReader(file1)); + offset = moveOffSet(file1, bufferedReader); if (logger.isDebugEnabled()) { logger.debug("Get file[{}] offset [{}]", file1.getName(), offset); } char[] chars = new char[OFFSET_FILE_READ_BUFFER_SIZE]; - StringBuilder data = new StringBuilder(2048); + data = new StringBuffer(2048); boolean bool = true; length = 0; while (bool) { diff --git a/skywalking-server/src/main/resources/config.properties b/skywalking-server/src/main/resources/config.properties index 2b1c50d64..4cf655049 100644 --- a/skywalking-server/src/main/resources/config.properties +++ b/skywalking-server/src/main/resources/config.properties @@ -1,5 +1,5 @@ #采集服务器的端口 -server.port=34000 +server.port=35000 #最大数据缓存线程数量 buffer.max_thread_number=1