From dd2108682a3424337b5aafc8315f9d28900c4ebe Mon Sep 17 00:00:00 2001 From: Andrew Purtell Date: Fri, 1 May 2026 16:18:04 -0700 Subject: [PATCH] PHOENIX-7824 ConcurrentMutationsExtendedIT fix wrong TimeUnit on doneSignal.await --- .../apache/phoenix/end2end/ConcurrentMutationsExtendedIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIT.java index 4e10284a32a..63c0484c784 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/ConcurrentMutationsExtendedIT.java @@ -377,7 +377,7 @@ public void run() { Thread t2 = new Thread(r2); t2.start(); - doneSignal.await(ROW_LOCK_WAIT_TIME + 5000, TimeUnit.SECONDS); + assertTrue("Ran out of time", doneSignal.await(60, TimeUnit.SECONDS)); assertNull(failedMsg[0], failedMsg[0]); if (eventual) { Thread.sleep(35000); @@ -439,7 +439,7 @@ public void run() { Thread t2 = new Thread(r2); t2.start(); - doneSignal.await(ROW_LOCK_WAIT_TIME + 5000, TimeUnit.SECONDS); + assertTrue("Ran out of time", doneSignal.await(60, TimeUnit.SECONDS)); if (eventual) { Thread.sleep(35000); }