This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push: new dfad916a40c branch-3.0: [bugfix](hive) fix_hive_metastore_client_socket_timeout #47378 (#50222) dfad916a40c is described below commit dfad916a40c447cb1c1b9d9bea488cb8f156110d Author: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com> AuthorDate: Tue Apr 22 11:07:12 2025 +0800 branch-3.0: [bugfix](hive) fix_hive_metastore_client_socket_timeout #47378 (#50222) Cherry-picked from #47378 Co-authored-by: zhangyuan <ayuanzh...@tencent.com> --- .../main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java | 2 +- .../java/org/apache/doris/datasource/hive/ThriftHMSCachedClient.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java index 2c80901da4a..8032dfbb1e2 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java @@ -176,7 +176,7 @@ public class HMSExternalCatalog extends ExternalCatalog { for (Map.Entry<String, String> kv : catalogProperty.getHadoopProperties().entrySet()) { hiveConf.set(kv.getKey(), kv.getValue()); } - hiveConf.set(HiveConf.ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT.name(), + HiveConf.setVar(hiveConf, HiveConf.ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT, String.valueOf(Config.hive_metastore_client_timeout_second)); } HiveMetadataOps hiveOps = ExternalMetadataOperations.newHiveMetadataOps(hiveConf, jdbcClientConfig, this); diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/ThriftHMSCachedClient.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/ThriftHMSCachedClient.java index 56b69dc71e2..04f4da2bcaf 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/ThriftHMSCachedClient.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/ThriftHMSCachedClient.java @@ -98,7 +98,7 @@ public class ThriftHMSCachedClient implements HMSCachedClient { public ThriftHMSCachedClient(HiveConf hiveConf, int poolSize) { Preconditions.checkArgument(poolSize > 0, poolSize); if (hiveConf != null) { - hiveConf.set(ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT.name(), + HiveConf.setVar(hiveConf, ConfVars.METASTORE_CLIENT_SOCKET_TIMEOUT, String.valueOf(Config.hive_metastore_client_timeout_second)); } this.hiveConf = hiveConf; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org