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

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


The following commit(s) were added to refs/heads/main by this push:
     new 66d47ae034 fixes RangedTableLocksIT (#5843)
66d47ae034 is described below

commit 66d47ae034d85c05aa9afa2dfc964eef85f75192
Author: Keith Turner <[email protected]>
AuthorDate: Fri Aug 29 12:11:44 2025 -0400

    fixes RangedTableLocksIT (#5843)
---
 .../main/java/org/apache/accumulo/test/fate/RangedTableLocksIT.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/fate/RangedTableLocksIT.java 
b/test/src/main/java/org/apache/accumulo/test/fate/RangedTableLocksIT.java
index e0ff12ba79..8f16f11f5e 100644
--- a/test/src/main/java/org/apache/accumulo/test/fate/RangedTableLocksIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/fate/RangedTableLocksIT.java
@@ -106,7 +106,8 @@ public class RangedTableLocksIT extends 
AccumuloClusterHarness {
 
       Wait.waitFor(() -> !getLocksInfo().heldLocks.isEmpty());
       var lockInfo = getLocksInfo();
-      assertEquals(lockInfo.heldLocks.keySet(), 
lockInfo.findId(LockRange.of(null, "b5")));
+      // For compactions the range (null, b5] will be widened to the table 
range (null,c]
+      assertEquals(lockInfo.heldLocks.keySet(), 
lockInfo.findId(LockRange.of(null, "c")));
 
       // this bulk will overlap the compaction range, but should not get stuck 
because both are read
       // locks
@@ -171,7 +172,7 @@ public class RangedTableLocksIT extends 
AccumuloClusterHarness {
 
       // remove the fate op that only has a lock on the namespace
       lockInfo.heldLocks.values().removeIf(idList -> 
idList.equals(List.of("R:+default")));
-      assertEquals(lockInfo.heldLocks.keySet(), 
lockInfo.findId(LockRange.of(null, "b5")));
+      assertEquals(lockInfo.heldLocks.keySet(), 
lockInfo.findId(LockRange.of(null, "c")));
       assertEquals(lockInfo.waitingLocks.keySet(),
           lockInfo.findId(LockRange.of("b", "d"), LockRange.of(null, "d"), 
LockRange.infinite()));
 

Reply via email to