flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
Subject git commit: FLUME-1848. HDFSDataStream logger is actually for a sequence file
Date Tue, 22 Jan 2013 02:09:26 GMT
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 <harishreedharan@gmail.com>
Authored: Mon Jan 21 18:08:11 2013 -0800
Committer: Hari Shreedharan <harishreedharan@gmail.com>
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;


Mime
View raw message