morningman commented on code in PR #13969:
URL: https://github.com/apache/doris/pull/13969#discussion_r1014550596
##########
fe/fe-core/src/main/java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java:
##########
@@ -135,28 +140,46 @@ public static String getFormat(String input) throws
DdlException {
}
}
- public static HiveMetaStoreClient getClient(String metaStoreUris) throws
DdlException {
+ public static IMetaStoreClient getClient(String metaStoreUris) throws
DdlException {
HiveConf hiveConf = new HiveConf();
hiveConf.setVar(HiveConf.ConfVars.METASTOREURIS, metaStoreUris);
- HiveMetaStoreClient hivemetastoreclient = null;
+ return getClient(hiveConf);
+ }
+
+ public static IMetaStoreClient getClient(HiveConf hiveConf) throws
DdlException {
+ hiveConf.set(ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT.name(),
+ String.valueOf(Config.hive_metastore_client_timeout_second));
+ Properties prop = hiveConf.getAllProperties();
+ for (String key : prop.stringPropertyNames()) {
+ LOG.info("cmy debug key: {}, value: {}", key,
prop.getProperty(key));
Review Comment:
Removed
##########
fe/fe-core/src/main/java/org/apache/doris/catalog/HiveMetaStoreClientHelper.java:
##########
@@ -135,28 +140,46 @@ public static String getFormat(String input) throws
DdlException {
}
}
- public static HiveMetaStoreClient getClient(String metaStoreUris) throws
DdlException {
+ public static IMetaStoreClient getClient(String metaStoreUris) throws
DdlException {
HiveConf hiveConf = new HiveConf();
hiveConf.setVar(HiveConf.ConfVars.METASTOREURIS, metaStoreUris);
- HiveMetaStoreClient hivemetastoreclient = null;
+ return getClient(hiveConf);
+ }
+
+ public static IMetaStoreClient getClient(HiveConf hiveConf) throws
DdlException {
+ hiveConf.set(ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT.name(),
+ String.valueOf(Config.hive_metastore_client_timeout_second));
+ Properties prop = hiveConf.getAllProperties();
+ for (String key : prop.stringPropertyNames()) {
+ LOG.info("cmy debug key: {}, value: {}", key,
prop.getProperty(key));
+ }
+ IMetaStoreClient metaStoreClient = null;
+ String type = hiveConf.get(HIVE_METASTORE_TYPE);
+ LOG.info("cmy debug type: {}", type);
Review Comment:
Removed
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
