Fix test_transparent_mv_mysql test case

Signed-off-by: shuming.li <[email protected]>
StarRocks · Dec 31, 2024 · ad1e62f · ad1e62f
1 parent e0465c9
commit ad1e62f
Show file tree

Hide file tree

Showing 5 changed files with 271 additions and 263 deletions.
diff --git a/...sql/optimizer/rule/transformation/materialization/compensation/MVCompensationBuilder.java b/...sql/optimizer/rule/transformation/materialization/compensation/MVCompensationBuilder.java
@@ -134,11 +134,19 @@ public TableCompensation getRefBaseTableCompensation(Table refBaseTable,
      */
     public TableCompensation getRefBaseTableCompensationByPartitionKeys(Table refBaseTable,
                                                                         Optional<LogicalScanOperator> scanOperatorOpt) {
+        Set<String> toRefreshPartitionNames = mvUpdateInfo.getBaseTableToRefreshPartitionNames(refBaseTable);
+        if (toRefreshPartitionNames == null) {
+            return TableCompensation.unknown();
+        }
+        if (toRefreshPartitionNames.isEmpty()) {
+            return TableCompensation.noCompensation();
+        }
         if (refBaseTable.isNativeTableOrMaterializedView()) {
             return OlapTableCompensation.build(refBaseTable, mvUpdateInfo, scanOperatorOpt);
         } else if (MvPartitionCompensator.isSupportPartitionCompensate(refBaseTable)) {
             return ExternalTableCompensation.build(refBaseTable, mvUpdateInfo, scanOperatorOpt);
         } else {
+            // TODO: support more ref base table types
             logMVRewrite(mv.getName(), "Unsupported ref base table type: {}", refBaseTable.getName());
             return TableCompensation.unknown();
         }

diff --git a/test/sql/test_agg_state/R/test_agg_state_with_sync_mv.sql b/test/sql/test_agg_state/R/test_agg_state_with_sync_mv.sql
@@ -1,4 +1,4 @@
--- name: test_agg_state_with_sync_mv
+-- name: test_agg_state_with_sync_mv @slow
 CREATE TABLE t1 ( 
 k1  date, 
 c0 boolean,

diff --git a/test/sql/test_agg_state/T/test_agg_state_with_sync_mv.sql b/test/sql/test_agg_state/T/test_agg_state_with_sync_mv.sql
@@ -1,4 +1,4 @@
--- name: test_agg_state_with_sync_mv
+-- name: test_agg_state_with_sync_mv @slow
 CREATE TABLE t1 ( 
 k1  date, 
 c0 boolean,