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 6d7d33accda2..90c200461add 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 @@ -86,7 +86,7 @@ public void lock() { if (!getLockProvider().tryLock(writeConfig.getLockAcquireWaitTimeoutInMs(), TimeUnit.MILLISECONDS)) { metrics.updateLockNotAcquiredMetric(); if (getLockProvider() instanceof FileSystemBasedLockProvider) { - fs.delete(new Path(((FileSystemBasedLockProvider) getLockProvider()).getCurrentOwnerLockInfo()), true); + fs.delete(new Path(((FileSystemBasedLockProvider) getLockProvider()).getLock()), true); LOG.warn("Lock is FileSystemBasedLockProvider, had deleted lock files to avoid blocking next write job"); } throw new HoodieLockException("Unable to acquire the lock. Current lock owner information : "