From 02089f20b49acfb3ab2f3acb4248855eaf9bfe8d Mon Sep 17 00:00:00 2001
From: Michael Stack <stack@apache.org>
Date: Wed, 12 Sep 2018 10:13:43 -0700
Subject: [PATCH] HBASE-21190 Log files and count of entries in each as we load
 from the MasterProcWAL store

Conflicts:
	hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java
---
 .../hbase/procedure2/store/wal/ProcedureWALFormatReader.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java
index 281292d3214..b8dbc259774 100644
--- a/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java
+++ b/hbase-procedure/src/main/java/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALFormatReader.java
@@ -113,6 +113,7 @@ public class ProcedureWALFormatReader {
   }
 
   public void read(ProcedureWALFile log, ProcedureWALFormat.Loader loader) throws IOException {
+    long count = 0;
     FSDataInputStream stream = log.getStream();
     try {
       boolean hasMore = true;
@@ -123,6 +124,7 @@ public class ProcedureWALFormatReader {
           hasMore = false;
           break;
         }
+        count++;
         switch (entry.getType()) {
           case PROCEDURE_WAL_INIT:
             readInitEntry(entry);
@@ -144,8 +146,9 @@ public class ProcedureWALFormatReader {
             throw new CorruptedWALProcedureStoreException("Invalid entry: " + entry);
         }
       }
+      LOG.info("Read " + count + " entries in " + log);
     } catch (InvalidProtocolBufferException e) {
-      LOG.error("got an exception while reading the procedure WAL: " + log, e);
+      LOG.error("While reading entry #" + count + " in " + log, e);
       loader.markCorruptedWAL(log, e);
     }