Updated Branches: refs/heads/flume-1.4 3c48288a4 -> 3d899a744
FLUME-1736: SpoolingFileLineReader must close the reader before renaming (Hari Shreedharan via Brock Noland) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/3d899a74 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/3d899a74 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/3d899a74 Branch: refs/heads/flume-1.4 Commit: 3d899a744168e386ad58761c4c23cae05f73526b Parents: 3c48288 Author: Brock Noland <[email protected]> Authored: Mon Nov 19 09:58:59 2012 -0600 Committer: Brock Noland <[email protected]> Committed: Mon Nov 19 09:59:13 2012 -0600 ---------------------------------------------------------------------- .../flume/client/avro/SpoolingFileLineReader.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/3d899a74/flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java ---------------------------------------------------------------------- diff --git a/flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java b/flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java index b37b730..8362299 100644 --- a/flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java +++ b/flume-ng-core/src/main/java/org/apache/flume/client/avro/SpoolingFileLineReader.java @@ -228,6 +228,7 @@ public class SpoolingFileLineReader implements LineReader { String newPath = currPath + completedSuffix; logger.info("Preparing to move file " + currPath + " to " + newPath); + currentFile.get().reader.close(); File newFile = new File(currPath); // Verify that spooling assumptions hold @@ -281,7 +282,6 @@ public class SpoolingFileLineReader implements LineReader { throw new FlumeException(message); } } - currentFile.get().reader.close(); } /**
