lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3940] Fix retry count increment in lock manager (#5387)

Browse Source
This commit is contained in:
Sagar Sumit
2022-04-22 02:22:05 +05:30
committed by GitHub
parent 4e1ac467da
commit de5fa1fe03
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -70,11 +70,12 @@ public class LockManager implements Serializable, AutoCloseable {
} }
LOG.info("Retrying to acquire lock..."); LOG.info("Retrying to acquire lock...");
Thread.sleep(maxWaitTimeInMs); Thread.sleep(maxWaitTimeInMs);
retryCount++;
} catch (HoodieLockException | InterruptedException e) { } catch (HoodieLockException | InterruptedException e) {
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);
} }
} finally {
retryCount++;
} }
} }
if (!acquired) { if (!acquired) {