This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new f0ae066475b [fix](hudi) Disable nested column pruning for HUDI tables 
to avoid potential issues (#59860)
f0ae066475b is described below

commit f0ae066475ba346dddc793c6b36dd079be7fb65c
Author: Socrates <[email protected]>
AuthorDate: Wed Jan 14 18:01:26 2026 +0800

    [fix](hudi) Disable nested column pruning for HUDI tables to avoid 
potential issues (#59860)
    
    ### What problem does this PR solve?
    
    Related PR: #57204
    
    Problem Summary:
    
    Disable nested column pruning for HUDI tables to avoid potential issues
---
 .../apache/doris/nereids/trees/plans/logical/LogicalFileScan.java   | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalFileScan.java
 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalFileScan.java
index 5d4c1167a82..a8860596299 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalFileScan.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalFileScan.java
@@ -200,6 +200,12 @@ public class LogicalFileScan extends 
LogicalCatalogRelation implements SupportPr
         if (table instanceof IcebergExternalTable) {
             return true;
         } else if (table instanceof HMSExternalTable) {
+            HMSExternalTable hmsTable = (HMSExternalTable) table;
+            if (hmsTable.getDlaType() == HMSExternalTable.DLAType.HUDI) {
+                // Don't prune nested column for HUDI table for now, because 
HUDI table
+                // may have some issues when pruning nested column.
+                return false;
+            }
             try {
                 ConnectContext connectContext = ConnectContext.get();
                 SessionVariable sessionVariable = 
connectContext.getSessionVariable();


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to