recover to lock

apache · May 29, 2024 · 9113b4b · 9113b4b
1 parent e69b175
commit 9113b4b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java b/...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 : "