Repository: flume Updated Branches: refs/heads/flume-1.6 6dbf51562 -> a601c97a2
FLUME-2346. idLogFileMap in Log can lose track of file ids. (Johny Rufus via Hari) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/a601c97a Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/a601c97a Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/a601c97a Branch: refs/heads/flume-1.6 Commit: a601c97a2376110b7fbe9a69f653a89f510cd333 Parents: 6dbf515 Author: Hari Shreedharan <[email protected]> Authored: Thu Oct 9 16:10:10 2014 -0700 Committer: Hari Shreedharan <[email protected]> Committed: Thu Oct 9 16:10:44 2014 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/flume/channel/file/Log.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/a601c97a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java index 5b581e1..e797797 100644 --- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java +++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java @@ -1029,11 +1029,12 @@ public class Log { try { writer.markCheckpoint(logWriteOrderID); } finally { + reader = LogFileFactory.getRandomReader(file, + encryptionKeyProvider, fsyncPerTransaction); + idLogFileMap.put(id, reader); writer.close(); } - reader = LogFileFactory.getRandomReader(file, - encryptionKeyProvider, fsyncPerTransaction); - idLogFileMap.put(id, reader); + LOGGER.debug("Updated checkpoint for file: " + file + "logWriteOrderID " + logWriteOrderID); idIterator.remove();
