This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit 72e80756e025b3270034e408c224e891b18a4156
Author: Hui Tian <827677...@qq.com>
AuthorDate: Thu May 12 15:43:29 2022 +0800
[Bug] (load) Broker load kerberos auth fail (#9494)
---
.../main/java/org/apache/doris/broker/hdfs/FileSystemManager.java | 6 +++++-
1 file changed, 5 insertions(+), 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 2c00a2ae96..64a875c0ae 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
@@ -45,6 +45,7 @@ import java.net.InetAddress;
import java.net.URISyntaxException;
import java.net.UnknownHostException;
import java.nio.ByteBuffer;
+import java.nio.channels.FileLock;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.security.PrivilegedExceptionAction;
@@ -285,10 +286,13 @@ public class FileSystemManager {
tmpFilePath ="/tmp/." +
principal.replace('/', '_') +
"_" + Long.toString(currentTime) +
- "_" + Integer.toString(randNumber);
+ "_" + Integer.toString(randNumber) +
+ "_" + Thread.currentThread().getId();
logger.info("create kerberos tmp file" + tmpFilePath);
FileOutputStream fileOutputStream = new
FileOutputStream(tmpFilePath);
+ FileLock lock = fileOutputStream.getChannel().lock();
fileOutputStream.write(base64decodedBytes);
+ lock.release();
fileOutputStream.close();
keytab = tmpFilePath;
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
