From 1e2740f85ecc986a4dabb44bc8f4d8428b3b84df Mon Sep 17 00:00:00 2001 From: stephen Date: Sat, 12 Oct 2024 16:31:44 +0800 Subject: [PATCH] update error message Signed-off-by: stephen --- .../rule/transformation/IcebergEqualityDeleteRewriteRule.java | 3 ++- .../com/starrocks/sql/plan/IcebergEqualityDeletePlanTest.java | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/com/starrocks/sql/optimizer/rule/transformation/IcebergEqualityDeleteRewriteRule.java b/fe/fe-core/src/main/java/com/starrocks/sql/optimizer/rule/transformation/IcebergEqualityDeleteRewriteRule.java index 30a392840e9f3..47aefe073c763 100644 --- a/fe/fe-core/src/main/java/com/starrocks/sql/optimizer/rule/transformation/IcebergEqualityDeleteRewriteRule.java +++ b/fe/fe-core/src/main/java/com/starrocks/sql/optimizer/rule/transformation/IcebergEqualityDeleteRewriteRule.java @@ -181,7 +181,8 @@ public List transform(OptExpression input, OptimizerContext conte ColumnRefFactory columnRefFactory = context.getColumnRefFactory(); boolean hasPartitionEvolution = deleteSchemas.stream().map(x -> x.specId).distinct().count() > 1; if (hasPartitionEvolution && !context.getSessionVariable().enableReadIcebergEqDeleteWithPartitionEvolution()) { - throw new StarRocksConnectorException("Equality delete files are not supported for tables with partition evolution"); + throw new StarRocksConnectorException("Equality delete files aren't supported for tables with partition evolution." + + "You can execute `set enable_read_iceberg_equality_delete_with_partition_evolution = true` then rerun it"); } LogicalIcebergScanOperator newScanOp = buildNewScanOperatorWithUnselectedAndExtendedField( diff --git a/fe/fe-core/src/test/java/com/starrocks/sql/plan/IcebergEqualityDeletePlanTest.java b/fe/fe-core/src/test/java/com/starrocks/sql/plan/IcebergEqualityDeletePlanTest.java index 731bd3027a49b..aaba77eae0290 100644 --- a/fe/fe-core/src/test/java/com/starrocks/sql/plan/IcebergEqualityDeletePlanTest.java +++ b/fe/fe-core/src/test/java/com/starrocks/sql/plan/IcebergEqualityDeletePlanTest.java @@ -483,7 +483,7 @@ org.apache.iceberg.Table getTable(String dbName, String tableName) throws StarRo String sql = "select k2 from iceberg_catalog.db.tbl"; ExceptionChecker.expectThrowsWithMsg(StarRocksConnectorException.class, - "Equality delete files are not supported for tables with partition evolution", + "Equality delete files aren't supported for tables with partition evolution", () -> UtFrameUtils.getFragmentPlan(starRocksAssert.getCtx(), sql)); starRocksAssert.getCtx().getSessionVariable().setEnableReadIcebergEqDeleteWithPartitionEvolution(true);