This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 6ef1211585e [bugfix](paimon)Use the fs cache, otherwise it will cause
OOM (#38552) (#40052)
6ef1211585e is described below
commit 6ef1211585e3a75b541c00d375053d2710fbdf7b
Author: Mingyu Chen <[email protected]>
AuthorDate: Wed Aug 28 21:42:36 2024 +0800
[bugfix](paimon)Use the fs cache, otherwise it will cause OOM (#38552)
(#40052)
bp #38552
Co-authored-by: wuwenchi <[email protected]>
---
.../java/org/apache/doris/datasource/property/PropertyConverter.java | 1 -
.../org/apache/doris/datasource/property/PropertyConverterTest.java | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
index 528a7e838cf..a0ea2d3b69e 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
@@ -311,7 +311,6 @@ public class PropertyConverter {
endpoint = endpoint.replace(OssProperties.OSS_PREFIX, "");
}
ossProperties.put(org.apache.hadoop.fs.aliyun.oss.Constants.ENDPOINT_KEY,
endpoint);
- ossProperties.put("fs.oss.impl.disable.cache", "true");
ossProperties.put("fs.oss.impl", getHadoopFSImplByScheme("oss"));
boolean hdfsEnabled =
Boolean.parseBoolean(props.getOrDefault(OssProperties.OSS_HDFS_ENABLED,
"false"));
if (LocationPath.isHdfsOnOssEndpoint(endpoint) || hdfsEnabled) {
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/datasource/property/PropertyConverterTest.java
b/fe/fe-core/src/test/java/org/apache/doris/datasource/property/PropertyConverterTest.java
index 48903df17bc..c9f96a79161 100644
---
a/fe/fe-core/src/test/java/org/apache/doris/datasource/property/PropertyConverterTest.java
+++
b/fe/fe-core/src/test/java/org/apache/doris/datasource/property/PropertyConverterTest.java
@@ -483,7 +483,7 @@ public class PropertyConverterTest extends
TestWithFeService {
+ " 'oss.secret_key' = 'skk'\n"
+ ");";
testS3CompatibleCatalogProperties(catalogName1,
OssProperties.OSS_PREFIX,
- "oss.oss-cn-beijing.aliyuncs.com", query1, 12, 17);
+ "oss.oss-cn-beijing.aliyuncs.com", query1, 12, 16);
String catalogName2 = "hms_minio";
String query2 = "create catalog " + catalogName2 + " properties (\n"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
