Repository: flume Updated Branches: refs/heads/flume-1.5 323a46614 -> 3f5db796f
FLUME-2325. Bucketwriter must be permanently closed only on idle and roll timeouts. (chenshangan via Hari Shreedharan) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/3f5db796 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/3f5db796 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/3f5db796 Branch: refs/heads/flume-1.5 Commit: 3f5db796fe0239e4885cc3ae3233e1224cfb3fb8 Parents: 323a466 Author: Hari Shreedharan <hshreedha...@apache.org> Authored: Tue Feb 18 17:16:00 2014 -0800 Committer: Hari Shreedharan <hshreedha...@apache.org> Committed: Tue Feb 18 17:17:24 2014 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/3f5db796/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java index 7fb3bdd..e82d13d 100644 --- a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java +++ b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java @@ -328,8 +328,8 @@ class BucketWriter { } if (callCloseCallback) { runCloseAction(); - } - closed = true; + closed = true; + } } /**
