You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by mp...@apache.org on 2013/01/25 21:49:25 UTC
git commit: FLUME-1878. FileChannel replay should print status every
10000 events.
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 <mp...@apache.org>
Authored: Fri Jan 25 12:48:52 2013 -0800
Committer: Mike Percy <mp...@apache.org>
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++;