Updated Branches: refs/heads/flume-1.3.0 a51e40421 -> b6686e7d9
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/b6686e7d Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/b6686e7d Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/b6686e7d Branch: refs/heads/flume-1.3.0 Commit: b6686e7d953209f6f1bb8f11c0b989c7b661958e Parents: a51e404 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:22:19 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/b6686e7d/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
