(paimon) branch master updated: [parquet] Improve ParquetReaderUtil column lookup diagnostics (#7493)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new f846f11b9a [parquet] Improve ParquetReaderUtil column lookup 
diagnostics (#7493)
f846f11b9a is described below

commit f846f11b9aa1bbfde7ed4104d58b7fb268a97397
Author: jackylee <qcsd2...@gmail.com>
AuthorDate: Fri Mar 20 20:20:20 2026 +0800

    [parquet] Improve ParquetReaderUtil column lookup diagnostics (#7493)
---
 .../org/apache/paimon/format/parquet/reader/ParquetReaderUtil.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetReaderUtil.java
 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetReaderUtil.java
index a7890953ad..a2741f869a 100644
--- 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetReaderUtil.java
+++ 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/reader/ParquetReaderUtil.java
@@ -372,7 +372,7 @@ public class ParquetReaderUtil {
     }
 
     /**
-     * Parquet's column names are case in sensitive. So when we look up 
columns we first check for
+     * Parquet's column names are case insensitive. So when we look up columns 
we first check for
      * exact match, and if that can not find we look for a case-insensitive 
match.
      */
     public static ColumnIO lookupColumnByName(GroupColumnIO groupColumnIO, 
String columnName) {
@@ -388,7 +388,10 @@ public class ParquetReaderUtil {
             }
         }
 
-        throw new RuntimeException("Can not find column io for parquet 
reader.");
+        throw new RuntimeException(
+                String.format(
+                        "ColumnIO for '%s' not found in Parquet schema under 
'%s'.",
+                        columnName, String.join(".", 
groupColumnIO.getFieldPath())));
     }
 
     public static GroupColumnIO getMapKeyValueColumn(GroupColumnIO 
groupColumnIO) {