This is an automated email from the ASF dual-hosted git repository.
junegunn pushed a commit to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.5 by this push:
new f2526ce0932 HBASE-29482 Bulkload fails with viewfs authentication
error (#7180)
f2526ce0932 is described below
commit f2526ce0932b5cedad4c2d091a05127d89541a6a
Author: Jaehui Lee <[email protected]>
AuthorDate: Thu Jul 31 00:32:01 2025 +0900
HBASE-29482 Bulkload fails with viewfs authentication error (#7180)
Signed-off-by: Junegunn Choi <[email protected]>
---
.../main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java
b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java
index d94cf1dba5f..fa95f292e28 100644
---
a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java
+++
b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java
@@ -428,7 +428,9 @@ public class LoadIncrementalHFiles extends Configured
implements Tool {
LOG.warn("Secure bulk load has been integrated into HBase core.");
}
-
fsDelegationToken.acquireDelegationToken(queue.peek().getFilePath().getFileSystem(getConf()));
+ Path path = queue.peek().getFilePath();
+ FileSystem fs =
path.getFileSystem(getConf()).resolvePath(path).getFileSystem(getConf());
+ fsDelegationToken.acquireDelegationToken(fs);
bulkToken = secureClient.prepareBulkLoad(admin.getConnection());
Pair<Multimap<ByteBuffer, LoadQueueItem>, Set<String>> pair = null;