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 24a7d47a9b7 branch-2.1: [Fix](oss-hdfs)Fix insert failure on Hive
partitioned table with oss-hdfs #55565 (#55668)
24a7d47a9b7 is described below
commit 24a7d47a9b7167e5a799fd236cdea68f114570ff
Author: Calvin Kirs <[email protected]>
AuthorDate: Sat Sep 6 00:11:55 2025 +0800
branch-2.1: [Fix](oss-hdfs)Fix insert failure on Hive partitioned table
with oss-hdfs #55565 (#55668)
#55565
---
.../java/org/apache/doris/common/util/LocationPath.java | 14 +-------------
.../org/apache/doris/fs/remote/RemoteFileSystemTest.java | 2 +-
2 files changed, 2 insertions(+), 14 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/util/LocationPath.java
b/fe/fe-core/src/main/java/org/apache/doris/common/util/LocationPath.java
index 7e8b357395c..71aaf5f27c8 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/util/LocationPath.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/LocationPath.java
@@ -131,19 +131,7 @@ public class LocationPath {
tmpLocation = convertPath ? convertToS3(tmpLocation) :
tmpLocation;
break;
case FeConstants.FS_PREFIX_OSS:
- String endpoint = "";
- if (props.containsKey(OssProperties.ENDPOINT)) {
- endpoint = props.get(OssProperties.ENDPOINT);
- if (endpoint.startsWith(OssProperties.OSS_PREFIX)) {
- // may use oss.oss-cn-beijing.aliyuncs.com
- endpoint = endpoint.replace(OssProperties.OSS_PREFIX,
"");
- }
- } else if (props.containsKey(S3Properties.ENDPOINT)) {
- endpoint = props.get(S3Properties.ENDPOINT);
- } else if (props.containsKey(S3Properties.Env.ENDPOINT)) {
- endpoint = props.get(S3Properties.Env.ENDPOINT);
- }
- if (isHdfsOnOssEndpoint(endpoint)) {
+ if (isHdfsOnOssEndpoint(originLocation)) {
this.scheme = Scheme.OSS_HDFS;
} else {
if (useS3EndPoint(props)) {
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/fs/remote/RemoteFileSystemTest.java
b/fe/fe-core/src/test/java/org/apache/doris/fs/remote/RemoteFileSystemTest.java
index 3fc15ab8e37..2b94dbf8bad 100644
---
a/fe/fe-core/src/test/java/org/apache/doris/fs/remote/RemoteFileSystemTest.java
+++
b/fe/fe-core/src/test/java/org/apache/doris/fs/remote/RemoteFileSystemTest.java
@@ -68,7 +68,7 @@ public class RemoteFileSystemTest {
dfsPaths.add("ofs://a/b/c");
dfsPaths.add("gfs://a/b/c");
dfsPaths.add("hdfs://a/b/c");
- dfsPaths.add("oss://a/b/c"); // if endpoint contains
'oss-dls.aliyuncs', will use dfs filesystem
+
dfsPaths.add("oss://emr-ssss-oss.cn-beijing.oss-dls.aliyuncs.com/tmp/"); // if
endpoint contains 'oss-dls.aliyuncs', will use dfs filesystem
new MockUp<UserGroupInformation>(UserGroupInformation.class) {
@Mock
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
