[hbase] branch branch-1 updated: HBASE-24077 When encounter RowTooBigException, log the row info. (#1379)

[ap...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

apurtell pushed a commit to branch branch-1
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-1 by this push:
     new 73d1c2a  HBASE-24077 When encounter RowTooBigException, log the row info. (#1379)
73d1c2a is described below

commit 73d1c2a10f48824c238f72a5f595f7ca6f32fbc2
Author: binlijin <bi...@gmail.com>
AuthorDate: Tue Apr 7 10:28:35 2020 +0800

    HBASE-24077 When encounter RowTooBigException, log the row info. (#1379)
    
    Signed-off-by: Viraj Jasani <vj...@apache.org>
    Signed-off-by: Pankaj <pa...@apache.org>
    Signed-off-by: Jan Hentschel <ja...@ultratendency.com>
---
 .../java/org/apache/hadoop/hbase/regionserver/StoreScanner.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
index f0fbf3e..c615925 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
@@ -608,8 +608,12 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
             scannerContext.incrementBatchProgress(1);
 
             if (matcher.isUserScan() && totalBytesRead > maxRowSize) {
-              throw new RowTooBigException("Max row size allowed: " + maxRowSize
-                  + ", but the row is bigger than that.");
+              String message = "Max row size allowed: " + maxRowSize
+                + ", but the row is bigger than that, the row info: " + CellUtil
+                .toString(cell, false) + ", already have process row cells = " + outResult.size()
+                + ", it belong to region = " + store.getRegionInfo().getRegionNameAsString();
+              LOG.warn(message);
+              throw new RowTooBigException(message);
             }
           }