From c700bf44c9c9b457c8639e607ef80b35394318ab 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; }