You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by br...@apache.org on 2013/01/28 02:37:05 UTC
git commit: FLUME-1880: Double-logging of created HDFS files
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 <br...@apache.org>
Authored: Sun Jan 27 19:36:34 2013 -0600
Committer: Brock Noland <br...@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) {