nsivabalan commented on code in PR #6549:
URL: https://github.com/apache/hudi/pull/6549#discussion_r959890858
##########
hudi-client/hudi-client-common/src/test/java/org/apache/hudi/client/transaction/TestInProcessLockProvider.java:
##########
@@ -160,6 +160,48 @@ public void testTryLockReAcquisitionByDifferentThread() {
});
}
+ @Test
+ public void testTryUnLockByDifferentThread() {
+ InProcessLockProvider inProcessLockProvider = new
InProcessLockProvider(lockConfiguration, hadoopConfiguration);
+ final AtomicBoolean writer2Completed = new AtomicBoolean(false);
+ final AtomicBoolean writer3Completed = new AtomicBoolean(false);
+
+ // Main test thread
+ Assertions.assertTrue(inProcessLockProvider.tryLock());
+
+ // Another writer thread
+ Thread writer2 = new Thread(() -> {
Review Comment:
sorry, some refactoring residues. will clean it up.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
