update error message

Signed-off-by: stephen <[email protected]>
StarRocks · Oct 12, 2024 · 1e2740f · 1e2740f
1 parent b918629
commit 1e2740f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...ava/com/starrocks/sql/optimizer/rule/transformation/IcebergEqualityDeleteRewriteRule.java b/...ava/com/starrocks/sql/optimizer/rule/transformation/IcebergEqualityDeleteRewriteRule.java
@@ -181,7 +181,8 @@ public List<OptExpression> 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
@@ -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);