database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](multi-catalog) Fix properties check in S3Storage and add hive socket timeout config (#18420)

Browse Source 
Co-authored-by: jinzhe <jinzhe@selectdb.com>
This commit is contained in:
slothever
2023-04-06 16:35:24 +08:00
committed by GitHub
parent 27576ef8dc
commit 33ae4524ce
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/backup/S3Storage.java
View File

@ -103,7 +103,7 @@ public class S3Storage extends BlobStorage {
S3Properties.convertToStdProperties(caseInsensitiveProperties);
}
try {
S3Properties.requiredS3Properties(properties);
S3Properties.requiredS3Properties(caseInsensitiveProperties);
} catch (DdlException e) {
throw new IllegalArgumentException(e);
}

2
fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java
View File

@ -163,6 +163,8 @@ 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(),
String.valueOf(Config.hive_metastore_client_timeout_second));
String authentication = catalogProperty.getOrDefault(
HdfsResource.HADOOP_SECURITY_AUTHENTICATION, "");
if (AuthType.KERBEROS.getDesc().equals(authentication)) {