Updated Branches: refs/heads/trunk a0a55703c -> dd1880231
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/dd188023 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/dd188023 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/dd188023 Branch: refs/heads/trunk Commit: dd1880231b7f8f64e2a0d4a43ebf7e95e0196562 Parents: a0a5570 Author: Jarek Jarcec Cecho <[email protected]> Authored: Tue Jul 31 08:55:32 2012 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Tue Jul 31 08:55:32 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/dd188023/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
