Updated Branches: refs/heads/flume-1.4 e8cbcd433 -> d7b474c37
FLUME-1878. FileChannel replay should print status every 10000 events. (Brock Noland via Mike Percy) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/d7b474c3 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/d7b474c3 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/d7b474c3 Branch: refs/heads/flume-1.4 Commit: d7b474c375d2531aee33570c6bb9ef7ccae5501b Parents: e8cbcd4 Author: Mike Percy <[email protected]> Authored: Fri Jan 25 12:48:52 2013 -0800 Committer: Mike Percy <[email protected]> Committed: Fri Jan 25 12:49:17 2013 -0800 ---------------------------------------------------------------------- .../apache/flume/channel/file/ReplayHandler.java | 3 +++ 1 files changed, 3 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/d7b474c3/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java index 81f6172..fa4fd9d 100644 --- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java +++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java @@ -273,6 +273,9 @@ class ReplayHandler { writeOrderIDSeed = Math.max(writeOrderIDSeed, record.getLogWriteOrderID()); readCount++; + if(readCount % 10000 == 0 && readCount > 0) { + LOG.info("Read " + readCount + " records"); + } if (record.getLogWriteOrderID() > lastCheckpoint) { if (type == TransactionEventRecord.Type.PUT.get()) { putCount++;
