From 1959b843b706babed8c16ee31c6fc266871d709f Mon Sep 17 00:00:00 2001 From: liujinhui <965147871@qq.com> Date: Mon, 18 Jul 2022 22:45:52 +0800 Subject: [PATCH] [HUDI-4409] Improve LockManager wait logic when catch exception (#6122) --- .../org/apache/hudi/client/transaction/lock/LockManager.java | 5 +++++ 1 file changed, 5 insertions(+) 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++; }