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 c384a094e14f34a021718a64e0bd2a6454d1140a..7dcb552084755d23fd6daa752fec2ac4404171fa 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 d748cc32b75ca4a170255f5d315eea6b2adcce77..9c0cd46c756db83d007240b47b4b7c5a256c1d8d 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); } }