From 07703633dd2a26e1c050a2ad58293a5898a376e6 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Thu, 29 Feb 2024 22:19:04 +0800 Subject: [PATCH] [pipelineX](conf) enable pipelineX by default (#29894) * update * update --- be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 4 ++-- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- .../suites/external_table_p0/hive/test_hive_other.groovy | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp index 0d1d7784f8..77a63209cc 100644 --- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp +++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp @@ -225,11 +225,11 @@ Status PipelineXFragmentContext::prepare(const doris::TPipelineFragmentParams& r request, root_pipeline->output_row_desc(), _runtime_state.get(), *_desc_tbl, root_pipeline->id())); RETURN_IF_ERROR(_sink->init(request.fragment.output_sink)); - static_cast(root_pipeline->set_sink(_sink)); + RETURN_IF_ERROR(root_pipeline->set_sink(_sink)); for (PipelinePtr& pipeline : _pipelines) { DCHECK(pipeline->sink_x() != nullptr) << pipeline->operator_xs().size(); - static_cast(pipeline->sink_x()->set_child(pipeline->operator_xs().back())); + RETURN_IF_ERROR(pipeline->sink_x()->set_child(pipeline->operator_xs().back())); } if (_enable_local_shuffle()) { RETURN_IF_ERROR(_plan_local_exchange(request.num_buckets, diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index e561ded693..3a6f120d50 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -849,7 +849,7 @@ public class SessionVariable implements Serializable, Writable { private boolean enablePipelineEngine = true; @VariableMgr.VarAttr(name = ENABLE_PIPELINE_X_ENGINE, fuzzy = false, varType = VariableAnnotation.EXPERIMENTAL) - private boolean enablePipelineXEngine = false; + private boolean enablePipelineXEngine = true; @VariableMgr.VarAttr(name = ENABLE_SHARED_SCAN, fuzzy = false, varType = VariableAnnotation.EXPERIMENTAL, needForward = true) diff --git a/regression-test/suites/external_table_p0/hive/test_hive_other.groovy b/regression-test/suites/external_table_p0/hive/test_hive_other.groovy index 5400c94fc8..a7502ac1dc 100644 --- a/regression-test/suites/external_table_p0/hive/test_hive_other.groovy +++ b/regression-test/suites/external_table_p0/hive/test_hive_other.groovy @@ -19,7 +19,7 @@ suite("test_hive_other", "p0,external,hive,external_docker,external_docker_hive" def q01 = { qt_q24 """ select name, count(1) as c from student group by name order by c desc;""" - qt_q25 """ select lo_orderkey, count(1) as c from lineorder group by lo_orderkey order by c desc;""" + qt_q25 """ select lo_orderkey, count(1) as c from lineorder group by lo_orderkey order by lo_orderkey asc, c desc;""" qt_q26 """ select * from test1 order by col_1;""" qt_q27 """ select * from string_table order by p_partkey desc;""" qt_q28 """ select * from account_fund order by batchno;"""