From e35c93896bce9a08d9353e4569abf14ec92d9a96 Mon Sep 17 00:00:00 2001 From: sunzhiwei Date: Mon, 17 Dec 2018 21:22:51 +0800 Subject: [PATCH 1/2] FLUME-3306.patch.RollingFileSink sink.directory not exits --- .../src/main/java/org/apache/flume/sink/RollingFileSink.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java b/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java index d48a3c82a3..0e83211917 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java +++ b/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java @@ -99,7 +99,9 @@ public void configure(Context context) { batchSize = context.getInteger("sink.batchSize", defaultBatchSize); - this.directory = new File(directory); + if (!this.directory.exists()){ + this.directory.mkdirs(); + } if (sinkCounter == null) { sinkCounter = new SinkCounter(getName()); From 92cedc06aa127118c6e0fbdc98368c10c3687b25 Mon Sep 17 00:00:00 2001 From: sunzhiwei Date: Mon, 7 Jan 2019 13:24:13 +0800 Subject: [PATCH 2/2] change Checkstyle --- .../src/main/java/org/apache/flume/sink/RollingFileSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java b/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java index 0e83211917..50897d9e45 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java +++ b/flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java @@ -99,7 +99,7 @@ public void configure(Context context) { batchSize = context.getInteger("sink.batchSize", defaultBatchSize); - if (!this.directory.exists()){ + if (!this.directory.exists()) { this.directory.mkdirs(); }