From aa3c89ceb6b3542d68fef71d28247a4fe85a7270 Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Sat, 14 Nov 2015 15:37:23 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=BC=82=E5=B8=B8=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E6=89=93=E5=8D=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../skywalking/reciever/buffer/AppendEOFFlagThread.java | 2 +- .../reciever/persistance/RegisterPersistenceThread.java | 5 ++--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/AppendEOFFlagThread.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/AppendEOFFlagThread.java index c384a094e1..7dcb552084 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/AppendEOFFlagThread.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/buffer/AppendEOFFlagThread.java @@ -32,7 +32,7 @@ class AppendEOFFlagThread extends Thread { bufferedWriter.flush(); bufferedWriter.close(); } catch (IOException e) { - + logger.error("Flush data file failed", e); } } } diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java index d748cc32b7..9c0cd46c75 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/RegisterPersistenceThread.java @@ -40,7 +40,6 @@ public class RegisterPersistenceThread extends Thread { } Collection fileRegisterEntries = MemoryRegister.instance().getEntries(); logger.info("file Register Entries size [{}]", fileRegisterEntries.size()); - BufferedWriter writer = null; try { writer = new BufferedWriter(new FileWriter(file)); } catch (IOException e) { @@ -52,7 +51,7 @@ public class RegisterPersistenceThread extends Thread { try { writer.write(fileRegisterEntry.toString() + "\n"); } catch (IOException e) { - e.printStackTrace(); + logger.error("Write file register entry to offset file failure", e); } } try { @@ -60,7 +59,7 @@ public class RegisterPersistenceThread extends Thread { writer.flush(); writer.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("Flush offset file failure", e); } } -- GitLab