FLUME-1391. Use sync() instead of syncFs() in HDFS Sink to be compatible with hadoop 0.20.2.
(Yongkun Wang via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/8657b075 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/8657b075 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/8657b075 Branch: refs/heads/cdh-1.2.0+24_intuit Commit: 8657b0750a80c7046453de62838c511048b82006 Parents: 8d9770e Author: Jarek Jarcec Cecho <[email protected]> Authored: Tue Jul 31 08:55:32 2012 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Fri Sep 7 13:08:40 2012 -0700 ---------------------------------------------------------------------- .../apache/flume/sink/hdfs/HDFSSequenceFile.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/8657b075/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java ---------------------------------------------------------------------- diff --git a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java index bcc6f20..ac9104d 100644 --- a/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java +++ b/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java @@ -74,7 +74,7 @@ public class HDFSSequenceFile implements HDFSWriter { @Override public void sync() throws IOException { - writer.syncFs(); + writer.sync(); } @Override
