flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mpe...@apache.org
Subject git commit: FLUME-1878. FileChannel replay should print status every 10000 events.
Date Fri, 25 Jan 2013 20:49:29 GMT
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 <mpercy@apache.org>
Authored: Fri Jan 25 12:48:52 2013 -0800
Committer: Mike Percy <mpercy@apache.org>
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++;


Mime
View raw message