Updated Branches: refs/heads/trunk 466c51902 -> 41a19a54f
FLUME-1595: HDFS SequenceFile implementation is not durable due to not using syncFs() (Mike Percy 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/41a19a54 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/41a19a54 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/41a19a54 Branch: refs/heads/trunk Commit: 41a19a54f0d5e821621936783d06e0bc1397caf9 Parents: 466c519 Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu Sep 20 11:20:55 2012 +0200 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu Sep 20 11:20:55 2012 +0200 ---------------------------------------------------------------------- .../apache/flume/sink/hdfs/HDFSSequenceFile.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/41a19a54/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 ac9104d..bcc6f20 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.sync(); + writer.syncFs(); } @Override
