lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-4409] Improve LockManager wait logic when catch exception (#6122)

Browse Source
This commit is contained in:
liujinhui
2022-07-18 22:45:52 +08:00
committed by GitHub
parent 9282611bae
commit 1959b843b7
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java
View File

@@ -74,6 +74,11 @@ public class LockManager implements Serializable, AutoCloseable {
if (retryCount >= maxRetries) { if (retryCount >= maxRetries) {
throw new HoodieLockException("Unable to acquire lock, lock object ", e); throw new HoodieLockException("Unable to acquire lock, lock object ", e);
} }
try {
Thread.sleep(maxWaitTimeInMs);
} catch (InterruptedException ex) {
// ignore InterruptedException here
}
} finally { } finally {
retryCount++; retryCount++;
} }