lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3064] Fixing a bug in TransactionManager and FileSystemTestLock (#4372)

Browse Source
This commit is contained in:
Sivabalan Narayanan
2021-12-18 08:52:11 -08:00
committed by GitHub
parent 733732be7b
commit dc40397fa9
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/FileSystemBasedLockProviderTestClass.java
View File

@@ -76,7 +76,7 @@ public class FileSystemBasedLockProviderTestClass implements LockProvider<String
try { try {
int numRetries = 0; int numRetries = 0;
while (fs.exists(new Path(lockPath + "/" + LOCK_NAME)) while (fs.exists(new Path(lockPath + "/" + LOCK_NAME))
&& (numRetries <= lockConfiguration.getConfig().getInteger(LOCK_ACQUIRE_NUM_RETRIES_PROP_KEY))) { && (numRetries++ <= lockConfiguration.getConfig().getInteger(LOCK_ACQUIRE_NUM_RETRIES_PROP_KEY))) {
Thread.sleep(lockConfiguration.getConfig().getInteger(LOCK_ACQUIRE_RETRY_WAIT_TIME_IN_MILLIS_PROP_KEY)); Thread.sleep(lockConfiguration.getConfig().getInteger(LOCK_ACQUIRE_RETRY_WAIT_TIME_IN_MILLIS_PROP_KEY));
} }
synchronized (LOCK_NAME) { synchronized (LOCK_NAME) {