You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ka...@apache.org on 2019/11/16 07:22:16 UTC

[phoenix] branch 4.14-HBase-1.3 updated: PHOENIX-5564 Restructure read repair to improve readability and correctness (addendum)

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

kadir pushed a commit to branch 4.14-HBase-1.3
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.14-HBase-1.3 by this push:
     new 42ee41b  PHOENIX-5564 Restructure read repair to improve readability and correctness (addendum)
42ee41b is described below

commit 42ee41b3d77dc1a6d49cb93e3c5ef0ebe72dba02
Author: Kadir <ko...@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