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();

Reply via email to