This is an automated email from the ASF dual-hosted git repository. kadir pushed a commit to branch 4.x-HBase-1.3 in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/4.x-HBase-1.3 by this push: new a9491b4 PHOENIX-5564 Restructure read repair to improve readability and correctness (addendum) a9491b4 is described below commit a9491b4339ceef1c09922c752147fd97068039cd Author: Kadir <kozde...@salesforce.com> AuthorDate: Fri Nov 15 23:00:18 2019 -0800 PHOENIX-5564 Restructure read repair to improve readability and correctness (addendum) --- .../src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java b/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java index 9ecf876..6acdfbc 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java @@ -326,7 +326,10 @@ public class GlobalIndexChecker extends BaseRegionObserver { // Delete the unverified row from index if it is old enough deleteRowIfAgedEnough(indexRowKey, row, ts, false); // Open a new scanner starting from the row after the current row - indexScan.setStartRow(indexRowKey); + byte[] nextIndexRowKey = new byte[indexRowKey.length + 1]; + System.arraycopy(indexRowKey, 0, nextIndexRowKey, 0, indexRowKey.length); + nextIndexRowKey[indexRowKey.length] = 0; + indexScan.setStartRow(nextIndexRowKey); scanner = region.getScanner(indexScan); // Skip this unverified row (i.e., do not return it to the client). Just retuning empty row is // sufficient to do that