lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1979] Optimize logic to improve code readability (#3037)

Browse Source 
Co-authored-by: wei.zhang2 <wei.zhang2@dmall.com>
This commit is contained in:
Wei
2021-06-05 19:40:45 +08:00
committed by GitHub
parent c2383ee904
commit dab13f7473
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveMetastoreBasedLockProvider.java
View File

@@ -184,18 +184,13 @@ public class HiveMetastoreBasedLockProvider implements LockProvider<LockResponse
this.lock = executor.submit(() -> hiveClient.lock(lockRequestFinal)) this.lock = executor.submit(() -> hiveClient.lock(lockRequestFinal))
.get(time, unit); .get(time, unit);
} catch (InterruptedException | TimeoutException e) { } catch (InterruptedException | TimeoutException e) {
if (this.lock != null && this.lock.getState() == LockState.ACQUIRED) { if (this.lock == null || this.lock.getState() != LockState.ACQUIRED) {
return;
} else if (lockRequest != null) {
LockResponse lockResponse = this.hiveClient.checkLock(lockRequest.getTxnid()); LockResponse lockResponse = this.hiveClient.checkLock(lockRequest.getTxnid());
if (lockResponse.getState() == LockState.ACQUIRED) { if (lockResponse.getState() == LockState.ACQUIRED) {
this.lock = lockResponse; this.lock = lockResponse;
return;
} else { } else {
throw e; throw e;
} }
} else {
throw e;
} }
} }
} }