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()));