Updated Branches: refs/heads/trunk 04b21c0b0 -> c1e3d5041
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/c1e3d504 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/c1e3d504 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/c1e3d504 Branch: refs/heads/trunk Commit: c1e3d5041b065f46cfc78a02ae835ed3711d7955 Parents: 04b21c0 Author: Mike Percy <[email protected]> Authored: Fri Jan 25 12:48:52 2013 -0800 Committer: Mike Percy <[email protected]> Committed: Fri Jan 25 12:48:52 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/c1e3d504/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++;
