You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/08/11 11:26:45 UTC
[doris] branch master updated: [Fix](Nereids) fix insert into table of random distribution for nereids (#22831)
This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 045843991a [Fix](Nereids) fix insert into table of random distribution for nereids (#22831)
045843991a is described below
commit 045843991ab63bb5a16cea51514d51222cd68f9a
Author: mch_ucchi <41...@users.noreply.github.com>
AuthorDate: Fri Aug 11 19:26:39 2023 +0800
[Fix](Nereids) fix insert into table of random distribution for nereids (#22831)
currently insert into a table of random distribution info is not supported, we fix it by set physical properties to Any.
---
.../plans/physical/PhysicalOlapTableSink.java | 37 ++++--
.../data/nereids_p0/insert_into_table/random.out | 137 +++++++++++++++++++++
.../nereids_p0/insert_into_table/aggregate.groovy | 2 +-
.../insert_into_table/complex_insert.groovy | 2 +-
.../nereids_p0/insert_into_table/ddl/random_t.sql | 21 ++++
.../nereids_p0/insert_into_table/duplicate.groovy | 2 +-
.../nereids_p0/insert_into_table/load.groovy | 2 +-
.../insert_into_table/no_partition.groovy | 2 +-
.../{unsupport_type.groovy => random.groovy} | 26 ++--
.../insert_into_table/type_cast_aggregate.groovy | 2 +-
.../insert_into_table/type_cast_duplicate.groovy | 2 +-
.../insert_into_table/type_cast_unique.groovy | 2 +-
.../nereids_p0/insert_into_table/unique.groovy | 2 +-
.../insert_into_table/unsupport_type.groovy | 2 +-
14 files changed, 208 insertions(+), 33 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalOlapTableSink.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalOlapTableSink.java
index 7327c7b6af..ac3ce8d4ac 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalOlapTableSink.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalOlapTableSink.java
@@ -19,8 +19,11 @@ package org.apache.doris.nereids.trees.plans.physical;
import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.Database;
+import org.apache.doris.catalog.DistributionInfo;
import org.apache.doris.catalog.HashDistributionInfo;
import org.apache.doris.catalog.OlapTable;
+import org.apache.doris.catalog.RandomDistributionInfo;
+import org.apache.doris.nereids.exceptions.AnalysisException;
import org.apache.doris.nereids.memo.GroupExpression;
import org.apache.doris.nereids.properties.DistributionSpecHash.ShuffleType;
import org.apache.doris.nereids.properties.LogicalProperties;
@@ -190,22 +193,30 @@ public class PhysicalOlapTableSink<CHILD_TYPE extends Plan> extends PhysicalSink
*/
public PhysicalProperties getRequirePhysicalProperties() {
if (targetTable.isPartitioned()) {
- HashDistributionInfo distributionInfo = ((HashDistributionInfo) targetTable.getDefaultDistributionInfo());
- List<Column> distributedColumns = distributionInfo.getDistributionColumns();
- List<Integer> columnIndexes = Lists.newArrayList();
- int idx = 0;
- for (int i = 0; i < targetTable.getFullSchema().size(); ++i) {
- if (targetTable.getFullSchema().get(i).equals(distributedColumns.get(idx))) {
- columnIndexes.add(i);
- idx++;
- if (idx == distributedColumns.size()) {
- break;
+ DistributionInfo distributionInfo = targetTable.getDefaultDistributionInfo();
+ if (distributionInfo instanceof HashDistributionInfo) {
+ HashDistributionInfo hashDistributionInfo
+ = ((HashDistributionInfo) targetTable.getDefaultDistributionInfo());
+ List<Column> distributedColumns = hashDistributionInfo.getDistributionColumns();
+ List<Integer> columnIndexes = Lists.newArrayList();
+ int idx = 0;
+ for (int i = 0; i < targetTable.getFullSchema().size(); ++i) {
+ if (targetTable.getFullSchema().get(i).equals(distributedColumns.get(idx))) {
+ columnIndexes.add(i);
+ idx++;
+ if (idx == distributedColumns.size()) {
+ break;
+ }
}
}
+ return PhysicalProperties.createHash(columnIndexes.stream()
+ .map(colIdx -> child().getOutput().get(colIdx).getExprId())
+ .collect(Collectors.toList()), ShuffleType.NATURAL);
+ } else if (distributionInfo instanceof RandomDistributionInfo) {
+ return PhysicalProperties.ANY;
+ } else {
+ throw new AnalysisException("Unknown distributionInfo for Nereids to calculate physical properties");
}
- return PhysicalProperties.createHash(columnIndexes.stream()
- .map(colIdx -> child().getOutput().get(colIdx).getExprId())
- .collect(Collectors.toList()), ShuffleType.NATURAL);
} else {
return PhysicalProperties.GATHER;
}
diff --git a/regression-test/data/nereids_p0/insert_into_table/random.out b/regression-test/data/nereids_p0/insert_into_table/random.out
new file mode 100644
index 0000000000..d42426a991
--- /dev/null
+++ b/regression-test/data/nereids_p0/insert_into_table/random.out
@@ -0,0 +1,137 @@
+-- This file is automatically generated. You should know what you did if you want to edit this
+-- !11 --
+\N \N \N \N \N \N \N \N
+1 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+1 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+2 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+2 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+3 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+4 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+4 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+5 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+5 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+6 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+6 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+7 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+7 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+8 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+8 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+9 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+9 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+10 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+10 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+11 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+11 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+12 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+12 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+13 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+
+-- !12 --
+\N \N \N \N \N \N \N \N
+\N \N \N \N \N \N \N \N
+1 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+1 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+1 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+1 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+2 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+2 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+2 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+2 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+3 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+3 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+4 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+4 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+4 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+4 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+5 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+5 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+5 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+5 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+6 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+6 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+6 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+6 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+7 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+7 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+7 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+7 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+8 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+8 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+8 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+8 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+9 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+9 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+9 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+9 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+10 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+10 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+10 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+10 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+11 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+11 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+11 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+11 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+12 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+12 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+12 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+12 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+13 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+13 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+
+-- !13 --
+\N \N \N \N \N \N \N \N
+\N \N \N \N \N \N \N \N
+1 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+1 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+1 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+1 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+1 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+1 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+2 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+2 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+2 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+2 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+2 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+2 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+3 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+3 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+3 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+4 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+4 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+4 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+4 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+5 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+5 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+5 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+5 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+6 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+6 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+6 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+6 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+7 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+7 1 10.0 23795.000000 5354529 2012-03-01 2012-03-01T01:00:01 0.524
+7 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+7 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+8 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+8 2 20.0 47545.000000 10698279 2012-03-02 2012-03-02T02:01:02 0.742
+8 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+8 3 40.0 95045.000000 21385779 2012-03-03 2012-03-03T03:02:03 1.037
+9 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+9 4 80.0 190045.000000 42760779 2012-03-04 2012-03-04T04:03:04 1.449
+9 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+9 5 160.0 380045.000000 85510779 2012-03-05 2012-03-05T05:04:05 2.031
+10 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+10 6 320.0 760045.000000 171010779 2012-03-06 2012-03-06T06:05:06 2.855
+10 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+10 7 640.0 1520045.000000 342010779 2012-03-07 2012-03-07T07:06:07 4.022
+11 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+11 8 1280.0 3040045.000000 684010779 2012-03-08 2012-03-08T08:07:08 5.675
+11 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+11 9 2560.0 6080045.000000 1368010779 2012-03-09 2012-03-09T09:08:09 8.014
+12 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+12 10 5120.0 12160045.000000 2736010779 2012-03-10 2012-03-10T10:09:10 11.325
+12 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+12 11 10240.0 24320045.000000 5472010779 2012-03-11 2012-03-11T11:10:11 16.009
+13 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+13 12 20480.0 48640045.000000 10944010779 2012-03-12 2012-03-12T12:11:12 22.634
+
diff --git a/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy b/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy
index 9665e5520d..53ed03d3d0 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/aggregate.groovy
@@ -22,7 +22,7 @@ suite("nereids_insert_aggregate") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql '''insert into nereids_insert_into_table_test.agg_t
select * except(kaint) from src'''
diff --git a/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy b/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy
index 458ae6cb3f..cf6168c71a 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/complex_insert.groovy
@@ -21,7 +21,7 @@ suite('complex_insert') {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql 'use nereids_insert_into_table_test'
diff --git a/regression-test/suites/nereids_p0/insert_into_table/ddl/random_t.sql b/regression-test/suites/nereids_p0/insert_into_table/ddl/random_t.sql
new file mode 100644
index 0000000000..f2c9263f70
--- /dev/null
+++ b/regression-test/suites/nereids_p0/insert_into_table/ddl/random_t.sql
@@ -0,0 +1,21 @@
+create table dup_t_type_cast_rd (
+ `id` int null,
+ `kint` int(11) null,
+ `kdbl` double null,
+ `kdcml` decimal(20, 6) null,
+ `kvchr` varchar(20) null,
+ `kdt` date null,
+ `kdtmv2` datetimev2(0) null,
+ `kdcml32v3` decimalv3(7, 3) null
+) engine=OLAP
+duplicate key(id)
+partition by range(id) (
+ partition p1 values less than ("3"),
+ partition p2 values less than ("5"),
+ partition p3 values less than ("7"),
+ partition p4 values less than ("15")
+)
+distributed by random buckets 4
+properties (
+ "replication_num"="1"
+);
diff --git a/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy b/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy
index 167952190c..cc6428df07 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/duplicate.groovy
@@ -22,7 +22,7 @@ suite("nereids_insert_duplicate") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql '''insert into dup_t
select * except(kaint) from src'''
diff --git a/regression-test/suites/nereids_p0/insert_into_table/load.groovy b/regression-test/suites/nereids_p0/insert_into_table/load.groovy
index 5894a0a45c..c32433a182 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/load.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/load.groovy
@@ -66,7 +66,7 @@ suite("load") {
'agg_nop_t', 'agg_t', 'agg_type_cast',
'dup_nop_t', 'dup_t', 'dup_type_cast',
'uni_nop_t', 'uni_t', 'uni_type_cast',
- 'arr_t'
+ 'arr_t', 'random_t'
]
for (String file in files) {
diff --git a/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy b/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy
index 6d327366c4..48f3890153 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/no_partition.groovy
@@ -22,7 +22,7 @@ suite('nereids_insert_no_partition') {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
explain {
// TODO: test turn off pipeline when dml, remove it if pipeline sink is ok
diff --git a/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy b/regression-test/suites/nereids_p0/insert_into_table/random.groovy
similarity index 53%
copy from regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy
copy to regression-test/suites/nereids_p0/insert_into_table/random.groovy
index 75bc38f594..03803d5554 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/random.groovy
@@ -15,22 +15,28 @@
// specific language governing permissions and limitations
// under the License.
-suite("nereids_insert_array_type") {
+suite('nereids_insert_random') {
sql 'use nereids_insert_into_table_test'
+ sql 'clean label from nereids_insert_into_table_test'
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
- test {
- sql 'insert into arr_t select id, kaint from src'
- exception 'type ARRAY<INT> is unsupported for Nereids'
- }
+ sql '''insert into dup_t_type_cast_rd
+ select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src'''
+ sql 'sync'
+ qt_11 'select * from dup_t_type_cast_rd order by id, kint'
- sql 'set enable_fallback_to_original_planner=true'
+ sql '''insert into dup_t_type_cast_rd with label label_dup_type_cast_cte_rd
+ with cte as (select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src)
+ select * from cte'''
+ sql 'sync'
+ qt_12 'select * from dup_t_type_cast_rd order by id, kint'
- sql 'insert into arr_t select id, kaint from src'
+ sql '''insert into dup_t_type_cast_rd partition (p1, p2) with label label_dup_type_cast_rd
+ select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src where id < 4'''
sql 'sync'
- sql 'select * from arr_t'
-}
\ No newline at end of file
+ qt_13 'select * from dup_t_type_cast_rd order by id, kint'
+}
diff --git a/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy b/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy
index b5ac0ba12f..a35e8a6dbf 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/type_cast_aggregate.groovy
@@ -22,7 +22,7 @@ suite("nereids_insert_aggregate_type_cast") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql '''insert into agg_t_type_cast
select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src'''
diff --git a/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy b/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy
index 3124c7570b..524f299dd4 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/type_cast_duplicate.groovy
@@ -22,7 +22,7 @@ suite("nereids_insert_duplicate") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql '''insert into dup_t_type_cast
select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src'''
diff --git a/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy b/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy
index a0edf47b46..865e9b2842 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/type_cast_unique.groovy
@@ -22,7 +22,7 @@ suite("nereids_insert_unique_type_cast") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql '''insert into uni_t_type_cast
select id, ktint, ksint, kint, kbint, kdtv2, kdtm, kdbl from src'''
diff --git a/regression-test/suites/nereids_p0/insert_into_table/unique.groovy b/regression-test/suites/nereids_p0/insert_into_table/unique.groovy
index f79332709a..f124c4d941 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/unique.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/unique.groovy
@@ -22,7 +22,7 @@ suite("nereids_insert_unique") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
sql '''insert into uni_t
select * except(kaint) from src'''
diff --git a/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy b/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy
index 75bc38f594..08d691982a 100644
--- a/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy
+++ b/regression-test/suites/nereids_p0/insert_into_table/unsupport_type.groovy
@@ -21,7 +21,7 @@ suite("nereids_insert_array_type") {
sql 'set enable_nereids_planner=true'
sql 'set enable_fallback_to_original_planner=false'
sql 'set enable_nereids_dml=true'
- sql 'set parallel_fragment_exec_instance_num=13'
+ sql 'set enable_strict_consistency_dml=true'
test {
sql 'insert into arr_t select id, kaint from src'
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org