From b7323453288086b2447fc5c482ac5ce31ca6f157 Mon Sep 17 00:00:00 2001 From: zhangyuan Date: Fri, 7 Mar 2025 17:06:52 +0800 Subject: [PATCH] [bugfix](hive) fix_hive_metastore_client_socket_timeout (#47378) --- .../org/apache/doris/datasource/hive/HMSExternalCatalog.java | 2 +- .../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 2c80901da4aa45..8032dfbb1e2419 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 @@ protected void initLocalObjectsImpl() { for (Map.Entry 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 56b69dc71e2b03..04f4da2bcaf8ae 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;