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

dlmarion pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/elasticity by this push:
     new 6657426fad Modify ClientTabletCacheImpl.findExtentsToHost end key 
comparison (#3812)
6657426fad is described below

commit 6657426fad041346acdc205573079606c4bdf889
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Thu Oct 5 08:03:37 2023 -0400

    Modify ClientTabletCacheImpl.findExtentsToHost end key comparison (#3812)
    
    The change in #3429 modified ClientTabletCache so that it would
    preload Tablets for Scanners. It appears this change may
    have caused the test in #3809 to fail. I modified the comparison
    of the range to the tablet end key using the same logic that
    ThriftScanner uses and it fixed the test.
    
    Fixes #3809
---
 .../org/apache/accumulo/core/clientImpl/ClientTabletCacheImpl.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/ClientTabletCacheImpl.java
 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/ClientTabletCacheImpl.java
index 85271cac69..5ae2d1a095 100644
--- 
a/core/src/main/java/org/apache/accumulo/core/clientImpl/ClientTabletCacheImpl.java
+++ 
b/core/src/main/java/org/apache/accumulo/core/clientImpl/ClientTabletCacheImpl.java
@@ -600,7 +600,8 @@ public class ClientTabletCacheImpl extends 
ClientTabletCache {
       var currTablet = extent;
 
       for (int i = 0; i < hostAheadCount; i++) {
-        if (currTablet.endRow() == null || !hostAheadRange.contains(new 
Key(currTablet.endRow()))) {
+        if (currTablet.endRow() == null || hostAheadRange
+            .afterEndKey(new 
Key(currTablet.endRow()).followingKey(PartialKey.ROW))) {
           break;
         }
 

Reply via email to