FLUME-1391. Use sync() instead of syncFs() in HDFS Sink to be compatible with hadoop 0.20.2.
(Yongkun Wang via Jarek Jarcec Cecho) git-svn-id: https://svn.apache.org/repos/asf/flume/trunk@1368361 13f79535-47bb-0310-9956-ffa450edef68 Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/68ebd5fa Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/68ebd5fa Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/68ebd5fa Branch: refs/heads/master Commit: 68ebd5fa1a8c9b5dc8efc9fc3e2bcd49fb32d1fe Parents: 81e309e Author: Mubarak Seyed <[email protected]> Authored: Thu Aug 2 06:33:15 2012 +0000 Committer: Mubarak Seyed <[email protected]> Committed: Thu Aug 2 06:33:15 2012 +0000 ---------------------------------------------------------------------- .../apache/flume/sink/hdfs/HDFSSequenceFile.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/68ebd5fa/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
