[Fix](Nereids) should not gather data when sink (#20330)

This commit is contained in:
mch_ucchi
2023-06-02 10:33:11 +08:00
committed by GitHub
parent 5a3b97bbf2
commit 9d8043e4c1
10 changed files with 11 additions and 3 deletions

View File

@ -286,7 +286,7 @@ public class PhysicalPlanTranslator extends DefaultPlanVisitor<PlanFragment, Pla
rootFragment = currentFragment;
}
if (isFragmentPartitioned(rootFragment)) {
if (!(physicalPlan instanceof PhysicalOlapTableSink) && isFragmentPartitioned(rootFragment)) {
rootFragment = exchangeToMergeFragment(rootFragment, context);
}

View File

@ -21,6 +21,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 '''insert into nereids_insert_into_table_test.agg_t

View File

@ -18,6 +18,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 'use nereids_insert_into_table_test'

View File

@ -21,6 +21,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 '''insert into dup_t

View File

@ -21,6 +21,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 '''insert into agg_nop_t

View File

@ -21,6 +21,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 '''insert into agg_t_type_cast

View File

@ -21,6 +21,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 '''insert into dup_t_type_cast

View File

@ -21,6 +21,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 '''insert into uni_t_type_cast

View File

@ -21,6 +21,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 '''insert into uni_t

View File

@ -20,12 +20,12 @@ 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'
test {
sql 'insert into arr_t select id, kaint from src'
// exception 'type ARRAY<INT> is unsupported for Nereids'
exception null
exception 'type ARRAY<INT> is unsupported for Nereids'
}
sql 'set enable_fallback_to_original_planner=true'