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