lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix build broken from #3186 (#3245)

Browse Source
This commit is contained in:
vinoth chandar
2021-07-08 14:23:52 -07:00
committed by GitHub
parent de07e61382
commit c50c24908a
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java
View File

@@ -134,10 +134,10 @@ public class TestHiveMetastoreBasedLockProvider extends HiveSyncFunctionalTestHa
HiveMetastoreBasedLockProvider lockProvider2 = new HiveMetastoreBasedLockProvider(lockConfiguration, hiveConf()); HiveMetastoreBasedLockProvider lockProvider2 = new HiveMetastoreBasedLockProvider(lockConfiguration, hiveConf());
lockComponent.setOperationType(DataOperationType.NO_TXN); lockComponent.setOperationType(DataOperationType.NO_TXN);
Assertions.assertTrue(lockProvider1.acquireLock(lockConfiguration.getConfig() Assertions.assertTrue(lockProvider1.acquireLock(lockConfiguration.getConfig()
.getLong(LOCK_ACQUIRE_WAIT_TIMEOUT_MS_PROP), TimeUnit.MILLISECONDS, lockComponent)); .getLong(LOCK_ACQUIRE_WAIT_TIMEOUT_MS_PROP_KEY), TimeUnit.MILLISECONDS, lockComponent));
try { try {
boolean acquireStatus = lockProvider2.acquireLock(lockConfiguration.getConfig() boolean acquireStatus = lockProvider2.acquireLock(lockConfiguration.getConfig()
.getLong(LOCK_ACQUIRE_WAIT_TIMEOUT_MS_PROP), TimeUnit.MILLISECONDS, lockComponent); .getLong(LOCK_ACQUIRE_WAIT_TIMEOUT_MS_PROP_KEY), TimeUnit.MILLISECONDS, lockComponent);
Assertions.assertFalse(acquireStatus); Assertions.assertFalse(acquireStatus);
} catch (IllegalArgumentException e) { } catch (IllegalArgumentException e) {
// expected // expected
@@ -146,7 +146,7 @@ public class TestHiveMetastoreBasedLockProvider extends HiveSyncFunctionalTestHa
// create the third HiveMetastoreBasedLockProvider to acquire lock // create the third HiveMetastoreBasedLockProvider to acquire lock
HiveMetastoreBasedLockProvider lockProvider3 = new HiveMetastoreBasedLockProvider(lockConfiguration, hiveConf()); HiveMetastoreBasedLockProvider lockProvider3 = new HiveMetastoreBasedLockProvider(lockConfiguration, hiveConf());
boolean acquireStatus = lockProvider3.acquireLock(lockConfiguration.getConfig() boolean acquireStatus = lockProvider3.acquireLock(lockConfiguration.getConfig()
.getLong(LOCK_ACQUIRE_WAIT_TIMEOUT_MS_PROP), TimeUnit.MILLISECONDS, lockComponent); .getLong(LOCK_ACQUIRE_WAIT_TIMEOUT_MS_PROP_KEY), TimeUnit.MILLISECONDS, lockComponent);
// we should acquired lock, since lockProvider1 has already released lock // we should acquired lock, since lockProvider1 has already released lock
Assertions.assertTrue(acquireStatus); Assertions.assertTrue(acquireStatus);
lockProvider3.unlock(); lockProvider3.unlock();