This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 07703633dd2a26e1c050a2ad58293a5898a376e6 Author: Gabriel <[email protected]> AuthorDate: Thu Feb 29 22:19:04 2024 +0800 [pipelineX](conf) enable pipelineX by default (#29894) * update * update --- be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 4 ++-- fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- regression-test/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 0d1d7784f88..77a63209cc6 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<void>(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<void>(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 e561ded693a..3a6f120d501 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 5400c94fc81..a7502ac1dc2 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;""" --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
