From 85c718e80bac6496219e34c9363514d47a61c273 Mon Sep 17 00:00:00 2001 From: heguanhui Date: Wed, 18 Jun 2025 20:44:07 +0800 Subject: [PATCH] [fix](hudi catalog) Fix the Kerberos authentication error when querying hudi table (#51713) ### What problem does this PR solve? This PR has resolved the Kerberos authentication error that occurs when Doris queries Hudi tables with Kerberos authentication enabled for the Hudi catalog. Problem Summary: When Kerberos authentication is enabled for the Hudi catalog, an error occurs when Doris queries a Hudi table. --- .../doris/datasource/hudi/source/HudiScanNode.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java index a6156924e27967..8e33dfb24692a1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hudi/source/HudiScanNode.java @@ -383,7 +383,14 @@ public List getSplits(int numBackends) throws UserException { partitionInit = true; } List splits = Collections.synchronizedList(new ArrayList<>()); - getPartitionsSplits(prunedPartitions, splits); + try { + hmsTable.getCatalog().getPreExecutionAuthenticator().execute(() -> { + getPartitionsSplits(prunedPartitions, splits); + return null; + }); + } catch (Exception e) { + throw new UserException(ExceptionUtils.getRootCauseMessage(e), e); + } return splits; }