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 dfc1dbfb590 branch-2.1: [bugfix](chdfs) fix hash collision in chdfs
file system cache #49486 (#50545)
dfc1dbfb590 is described below
commit dfc1dbfb5901b4d373436384fa8c180f71df3b85
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Apr 30 09:16:37 2025 +0800
branch-2.1: [bugfix](chdfs) fix hash collision in chdfs file system cache
#49486 (#50545)
Cherry-picked from #49486
Co-authored-by: zhangyuan <[email protected]>
---
.../src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java
b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java
index beeff588bcb..e10636322a0 100644
---
a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java
+++
b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java
@@ -662,7 +662,7 @@ public class FileSystemManager {
*/
public BrokerFileSystem getChdfsFileSystem(String path, Map<String,
String> properties) {
WildcardURI pathUri = new WildcardURI(path);
- String host = CHDFS_SCHEME;
+ String host = CHDFS_SCHEME + "://" + pathUri.getAuthority();
String authentication =
properties.getOrDefault(CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHENTICATION,
AUTHENTICATION_SIMPLE);
if (Strings.isNullOrEmpty(authentication) ||
(!authentication.equals(AUTHENTICATION_SIMPLE)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
