This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 7dc4d3ac356 branch-3.1: [opt](iceberg) opt the error msg of iceberg
scan node #56327 (#56370)
7dc4d3ac356 is described below
commit 7dc4d3ac356d64ceb03e5b8e67b595c0c6861eb5
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu Sep 25 17:35:27 2025 +0800
branch-3.1: [opt](iceberg) opt the error msg of iceberg scan node #56327
(#56370)
Cherry-picked from #56327
Co-authored-by: Mingyu Chen (Rayner) <[email protected]>
---
.../doris/datasource/iceberg/source/IcebergScanNode.java | 13 ++++++++-----
.../iceberg/test_iceberg_partition_evolution.groovy | 2 +-
2 files changed, 9 insertions(+), 6 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/source/IcebergScanNode.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/source/IcebergScanNode.java
index 33c42af7eb9..5fcbe1def75 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/source/IcebergScanNode.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/source/IcebergScanNode.java
@@ -29,6 +29,7 @@ import org.apache.doris.common.DdlException;
import org.apache.doris.common.UserException;
import org.apache.doris.common.security.authentication.ExecutionAuthenticator;
import org.apache.doris.common.util.LocationPath;
+import org.apache.doris.common.util.Util;
import org.apache.doris.datasource.ExternalTable;
import org.apache.doris.datasource.ExternalUtil;
import org.apache.doris.datasource.FileQueryScanNode;
@@ -656,13 +657,15 @@ public class IcebergScanNode extends FileQueryScanNode {
EXAMPLE:
CREATE TABLE iceberg_tb(col1 INT,col2 STRING) USING ICEBERG
PARTITIONED BY (bucket(10,col2));
INSERT INTO iceberg_tb VALUES( ... );
- ALTER TABLE iceberg_tb DROP PARTITION FIELD bucket(10,col2);
- ALTER TABLE iceberg_tb DROP COLUMNS col2 STRING;
+ ALTER TABLE iceberg_tb DROP PARTITION FIELD bucket(10,col2);
+ ALTER TABLE iceberg_tb DROP COLUMNS col2;
Link: https://github.com/apache/iceberg/pull/10755
- */
- LOG.warn("Iceberg TableScanUtil.splitFiles throw
NullPointerException. Cause : ", e);
+ */
+ LOG.warn("Unable to plan for iceberg table {}",
this.desc.getTable().getName(), e);
return Optional.of(
- new NotSupportedException("Unable to read Iceberg table with
dropped old partition column."));
+ new NotSupportedException("Unable to plan for this table. "
+ + "Maybe read Iceberg table with dropped old
partition column. Cause: "
+ + Util.getRootCauseMessage(e)));
}
return Optional.empty();
}
diff --git
a/regression-test/suites/external_table_p0/iceberg/test_iceberg_partition_evolution.groovy
b/regression-test/suites/external_table_p0/iceberg/test_iceberg_partition_evolution.groovy
index 985f9e035cb..55a87d38536 100644
---
a/regression-test/suites/external_table_p0/iceberg/test_iceberg_partition_evolution.groovy
+++
b/regression-test/suites/external_table_p0/iceberg/test_iceberg_partition_evolution.groovy
@@ -88,7 +88,7 @@ suite("test_iceberg_partition_evolution",
"p0,external,doris,external_docker,ext
try {
sql """ select * from iceberg_evolution_partition """
}catch (Exception e) {
- assertTrue(e.getMessage().contains("Unable to read Iceberg table with
dropped old partition column."), e.getMessage())
+ assertTrue(e.getMessage().contains("Unable to plan for this table"),
e.getMessage())
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
