[Coral-Service] Replace create HiveMetaStoreClient to RetryingMetaSto…

…reClient (#480)
linkedin · Apr 7, 2024 · 3ffebec · 3ffebec
1 parent c0c151a
commit 3ffebec
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/coral-service/src/main/java/com/linkedin/coral/coralservice/metastore/MetastoreProvider.java b/coral-service/src/main/java/com/linkedin/coral/coralservice/metastore/MetastoreProvider.java
@@ -15,8 +15,8 @@
 import com.google.common.base.Strings;
 
 import org.apache.hadoop.hive.conf.HiveConf;
-import org.apache.hadoop.hive.metastore.HiveMetaStoreClient;
 import org.apache.hadoop.hive.metastore.IMetaStoreClient;
+import org.apache.hadoop.hive.metastore.RetryingMetaStoreClient;
 import org.apache.hadoop.hive.metastore.api.MetaException;
 import org.apache.hadoop.security.UserGroupInformation;
 
@@ -97,6 +97,6 @@ private static IMetaStoreClient getRemoteMetastoreClient(Properties props)
       UserGroupInformation.setConfiguration(conf);
       UserGroupInformation.loginUserFromKeytab(clientPrincipal, clientKeytab);
     }
-    return new HiveMetaStoreClient(conf);
+    return RetryingMetaStoreClient.getProxy(conf);
   }
 }