From 24f133d8e22050147c89fc127acb2f99654b0849 Mon Sep 17 00:00:00 2001 From: wusheng Date: Tue, 29 Nov 2016 22:22:31 +0800 Subject: [PATCH] remove useless config, and make sure file writer is flush. --- .../com/a/eye/skywalking/storage/config/Config.java | 10 ---------- .../skywalking/storage/data/file/DataFileWriter.java | 10 ++++++---- 2 files changed, 6 insertions(+), 14 deletions(-) diff --git a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/config/Config.java b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/config/Config.java index 755cc4ede..b92d7eed5 100644 --- a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/config/Config.java +++ b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/config/Config.java @@ -13,16 +13,6 @@ public class Config { } - public static class DataConsumer { - - public static int CHANNEL_SIZE = 10; - - public static int BUFFER_SIZE = 1000; - - public static int CONSUMER_SIZE = 5; - } - - public static class DataFile { public static String PATH = "/data/file"; diff --git a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/file/DataFileWriter.java b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/file/DataFileWriter.java index 87e3ca525..1d4a72ad6 100644 --- a/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/file/DataFileWriter.java +++ b/skywalking-storage-center/skywalking-storage/src/main/java/com/a/eye/skywalking/storage/data/file/DataFileWriter.java @@ -20,12 +20,14 @@ public class DataFileWriter { } IndexMetaCollection collections = new IndexMetaCollection(); - for (SpanData data : spanData) { - collections.add(dataFile.write(data)); + try { + for (SpanData data : spanData) { + collections.add(dataFile.write(data)); + } + }finally { + dataFile.flush(); } - dataFile.flush(); - return collections; }