diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java index 913736cad..ca15c4fdc 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java @@ -70,11 +70,12 @@ public class LockManager implements Serializable, AutoCloseable { } LOG.info("Retrying to acquire lock..."); Thread.sleep(maxWaitTimeInMs); - retryCount++; } catch (HoodieLockException | InterruptedException e) { if (retryCount >= maxRetries) { throw new HoodieLockException("Unable to acquire lock, lock object ", e); } + } finally { + retryCount++; } } if (!acquired) {