Updated Branches: refs/heads/flume-1.4 f098440a8 -> 90b5ed744
FLUME-1848. HDFSDataStream logger is actually for a sequence file (Brock Noland 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/90b5ed74 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/90b5ed74 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/90b5ed74 Branch: refs/heads/flume-1.4 Commit: 90b5ed744c4544d42e9c13af8a7ecac451a44823 Parents: f098440 Author: Hari Shreedharan <[email protected]> Authored: Mon Jan 21 18:08:11 2013 -0800 Committer: Hari Shreedharan <[email protected]> Committed: Mon Jan 21 18:09:02 2013 -0800 ---------------------------------------------------------------------- .../flume/sink/hdfs/HDFSCompressedDataStream.java | 1 - .../org/apache/flume/sink/hdfs/HDFSDataStream.java | 2 +- 2 files changed, 1 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/90b5ed74/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java index 95eb252..1f3521e 100644 --- a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java +++ b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java @@ -90,7 +90,6 @@ public class HDFSCompressedDataStream implements HDFSWriter { } else { fsOut = hdfs.create(dstPath); } - System.out.println("fsOut " + fsOut); cmpOut = codec.createOutputStream(fsOut); serializer = EventSerializerFactory.getInstance(serializerType, serializerContext, cmpOut); http://git-wip-us.apache.org/repos/asf/flume/blob/90b5ed74/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java index 04120ec..4ea4327 100644 --- a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java +++ b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java @@ -36,7 +36,7 @@ import org.slf4j.LoggerFactory; public class HDFSDataStream implements HDFSWriter { private static final Logger logger = - LoggerFactory.getLogger(HDFSSequenceFile.class); + LoggerFactory.getLogger(HDFSDataStream.class); private FSDataOutputStream outStream; private String serializerType;
