From aa0ecd9c90db410987e442e3db0b3a16f8822ea0 Mon Sep 17 00:00:00 2001 From: Youngju KIM Date: Mon, 20 May 2024 10:16:55 +0900 Subject: [PATCH] =?UTF-8?q?HBASE-28599=C2=A0RowTooBigException=20is=20thro?= =?UTF-8?q?wn=20when=20duplicate=20increment=20RPC=20call=20is=20attempted?= =?UTF-8?q?=20(#5927)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The root cause is analyzed by Robin Infant A(robiee17) Signed-off-by: Duo Zhang --- .../main/java/org/apache/hadoop/hbase/regionserver/HRegion.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index c55090d3a756..fdc50bc69476 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -4036,7 +4036,7 @@ private static Get toGet(final Mutation mutation) throws IOException { assert mutation instanceof Increment || mutation instanceof Append; Get get = new Get(mutation.getRow()); CellScanner cellScanner = mutation.cellScanner(); - while (!cellScanner.advance()) { + while (cellScanner.advance()) { Cell cell = cellScanner.current(); get.addColumn(CellUtil.cloneFamily(cell), CellUtil.cloneQualifier(cell)); }