flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From br...@apache.org
Subject git commit: FLUME-1880: Double-logging of created HDFS files
Date Mon, 28 Jan 2013 01:37:05 GMT
Updated Branches:
  refs/heads/trunk dca895d80 -> f5d31f7a6


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/f5d31f7a
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/f5d31f7a
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/f5d31f7a

Branch: refs/heads/trunk
Commit: f5d31f7a68e87c8bcc9ca5d43e5a29180d35b47d
Parents: dca895d
Author: Brock Noland <brock@apache.org>
Authored: Sun Jan 27 19:36:34 2013 -0600
Committer: Brock Noland <brock@apache.org>
Committed: Sun Jan 27 19:36:34 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/f5d31f7a/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) {


Mime
View raw message