This is an automated email from the ASF dual-hosted git repository.
vinoth pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new c50c249 [MINOR] Fix build broken from #3186 (#3245)
c50c249 is described below
commit c50c24908a4eb1ed769efb8878e6075d3e162d55
Author: vinoth chandar <[email protected]>
AuthorDate: Thu Jul 8 14:23:52 2021 -0700
[MINOR] Fix build broken from #3186 (#3245)
---
.../hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java
b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java
index 53190fa..8ae002c 100644
---
a/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java
+++
b/hudi-sync/hudi-hive-sync/src/test/java/org/apache/hudi/hive/functional/TestHiveMetastoreBasedLockProvider.java
@@ -134,10 +134,10 @@ public class TestHiveMetastoreBasedLockProvider extends
HiveSyncFunctionalTestHa
HiveMetastoreBasedLockProvider lockProvider2 = new
HiveMetastoreBasedLockProvider(lockConfiguration, hiveConf());
lockComponent.setOperationType(DataOperationType.NO_TXN);
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 {
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);
} catch (IllegalArgumentException e) {
// expected
@@ -146,7 +146,7 @@ public class TestHiveMetastoreBasedLockProvider extends
HiveSyncFunctionalTestHa
// create the third HiveMetastoreBasedLockProvider to acquire lock
HiveMetastoreBasedLockProvider lockProvider3 = new
HiveMetastoreBasedLockProvider(lockConfiguration, hiveConf());
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
Assertions.assertTrue(acquireStatus);
lockProvider3.unlock();