Updated Branches: refs/heads/flume-1.4 7d3e26e2a -> 3f0971cb9
FLUME-1880: Double-logging of created HDFS files (Mike Percy via Brock Noland) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/3f0971cb Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/3f0971cb Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/3f0971cb Branch: refs/heads/flume-1.4 Commit: 3f0971cb9a8c985889739330543a9e3b2a4d0721 Parents: 7d3e26e Author: Brock Noland <[email protected]> Authored: Sun Jan 27 19:36:34 2013 -0600 Committer: Brock Noland <[email protected]> Committed: Sun Jan 27 19:36:49 2013 -0600 ---------------------------------------------------------------------- .../org/apache/flume/sink/hdfs/BucketWriter.java | 2 -- 1 files changed, 0 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/3f0971cb/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 3f31ef2..1ff1984 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 @@ -227,12 +227,10 @@ class BucketWriter { // Need to get reference to FS using above config before underlying // writer does in order to avoid shutdown hook & IllegalStateExceptions fileSystem = new Path(bucketPath).getFileSystem(config); - LOG.info("Creating " + bucketPath); writer.open(bucketPath); } else { // need to get reference to FS before writer does to avoid shutdown hook fileSystem = new Path(bucketPath).getFileSystem(config); - LOG.info("Creating " + bucketPath); writer.open(bucketPath, codeC, compType); } } catch (Exception ex) {
