You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by pa...@apache.org on 2024/08/17 00:20:01 UTC
(phoenix) branch 5.2 updated: PHOENIX-7385 : Fix MetadataGetTableReadLockIT flapper (#1954) (#1956)
This is an automated email from the ASF dual-hosted git repository.
palashc pushed a commit to branch 5.2
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/5.2 by this push:
new 9f902e1424 PHOENIX-7385 : Fix MetadataGetTableReadLockIT flapper (#1954) (#1956)
9f902e1424 is described below
commit 9f902e1424d289c3413a89fc8df7ada256466b91
Author: Palash Chauhan <pa...@gmail.com>
AuthorDate: Fri Aug 16 17:19:56 2024 -0700
PHOENIX-7385 : Fix MetadataGetTableReadLockIT flapper (#1954) (#1956)
Co-authored-by: Palash Chauhan <p....@pchauha-ltm8owy.internal.salesforce.com>
---
.../org/apache/phoenix/end2end/MetadataGetTableReadLockIT.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MetadataGetTableReadLockIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MetadataGetTableReadLockIT.java
index 7fd98801e2..589748c491 100644
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/MetadataGetTableReadLockIT.java
+++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/MetadataGetTableReadLockIT.java
@@ -41,7 +41,7 @@ import java.util.concurrent.CountDownLatch;
/**
* Class which tests whether non-exclusive locking on metadata read path (getTable) works as expected.
*/
-@Category(ParallelStatsDisabledTest.class)
+@Category(NeedsOwnMiniClusterTest.class)
public class MetadataGetTableReadLockIT extends BaseTest {
@BeforeClass
@@ -123,16 +123,17 @@ public class MetadataGetTableReadLockIT extends BaseTest {
@Override
protected Region.RowLock acquireLock(Region region, byte[] lockKey, List<Region.RowLock> locks, boolean readLock) throws IOException {
+ long tmpSleepDuration = sleepDuration;
Region.RowLock rowLock = region.getRowLock(lockKey, this.getMetadataReadLockEnabled && readLock);
if (rowLock == null) {
throw new IOException("Failed to acquire lock on " + Bytes.toStringBinary(lockKey));
}
- sleepSignal.countDown();
if (locks != null) {
locks.add(rowLock);
}
+ sleepSignal.countDown();
try {
- Thread.sleep(sleepDuration);
+ Thread.sleep(tmpSleepDuration);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}