Repository: hbase
Updated Branches:
  refs/heads/branch-1 00a4e0697 -> 19fffacd3
  refs/heads/branch-1.4 b2eb09aa2 -> c51c78469
  refs/heads/branch-2 2e069df6b -> 7fef60634
  refs/heads/master 192e87309 -> 70d48b113


HBASE-18623 Frequent failed to parse at EOF warnings from WALEntryStream


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/19fffacd
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/19fffacd
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/19fffacd

Branch: refs/heads/branch-1
Commit: 19fffacd3a95bc6eebd3ea3bc0d9ff0a2593e37b
Parents: 00a4e06
Author: Andrew Purtell <apurt...@apache.org>
Authored: Fri Aug 18 17:13:51 2017 -0700
Committer: Andrew Purtell <apurt...@apache.org>
Committed: Mon Aug 21 09:29:20 2017 -0700

----------------------------------------------------------------------
 .../hbase/replication/regionserver/WALEntryStream.java       | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/19fffacd/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
----------------------------------------------------------------------
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
index 4f49955..3942d23 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryStream.java
@@ -233,9 +233,11 @@ public class WALEntryStream implements Iterator<Entry>, 
Closeable, Iterable<Entr
       if (trailerSize < 0) {
         if (currentPosition < stat.getLen()) {
           final long skippedBytes = stat.getLen() - currentPosition;
-          LOG.info("Reached the end of WAL file '" + currentPath
-              + "'. It was not closed cleanly, so we did not parse " + 
skippedBytes
-              + " bytes of data.");
+          if (LOG.isDebugEnabled()) {
+            LOG.debug("Reached the end of WAL file '" + currentPath
+                + "'. It was not closed cleanly, so we did not parse " + 
skippedBytes
+                + " bytes of data. This is normally ok.");
+          }
           metrics.incrUncleanlyClosedWALs();
           metrics.incrBytesSkippedInUncleanlyClosedWALs(skippedBytes);
         }

Reply via email to