From 5c68f6936250fa8bed1560461cc0059cbccd3795 Mon Sep 17 00:00:00 2001 From: Pxl Date: Wed, 12 Oct 2022 09:07:24 +0800 Subject: [PATCH] [improvement](config) set enable_local_exchange default value to true (#13292) --- be/src/vec/sink/vdata_stream_sender.h | 2 +- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- tools/tpch-tools/queries/q3.sql | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/be/src/vec/sink/vdata_stream_sender.h b/be/src/vec/sink/vdata_stream_sender.h index f3b561c625e3d9..049de75d0e513f 100644 --- a/be/src/vec/sink/vdata_stream_sender.h +++ b/be/src/vec/sink/vdata_stream_sender.h @@ -309,7 +309,7 @@ class VDataStreamSender::Channel { PBlock _ch_pb_block1; PBlock _ch_pb_block2; - bool _enable_local_exchange = false; + bool _enable_local_exchange = true; }; template 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 ee1a5e7627c0ff..c079cf7041e868 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 @@ -555,7 +555,7 @@ public class SessionVariable implements Serializable, Writable { public boolean enableFunctionPushdown; @VariableMgr.VarAttr(name = ENABLE_LOCAL_EXCHANGE) - public boolean enableLocalExchange = false; + public boolean enableLocalExchange = true; /** * For debugg purpose, dont' merge unique key and agg key when reading data. diff --git a/tools/tpch-tools/queries/q3.sql b/tools/tpch-tools/queries/q3.sql index 01561b56cc334b..0bd7a59a0a3574 100644 --- a/tools/tpch-tools/queries/q3.sql +++ b/tools/tpch-tools/queries/q3.sql @@ -17,7 +17,7 @@ -- Modified -select /*+SET_VAR(exec_mem_limit=8589934592, parallel_fragment_exec_instance_num=8, enable_vectorized_engine=true, batch_size=4096, disable_join_reorder=true, enable_cost_based_join_reorder=false, enable_projection=true) */ +select /*+SET_VAR(exec_mem_limit=8589934592, parallel_fragment_exec_instance_num=8, enable_vectorized_engine=true, batch_size=4096, disable_join_reorder=true, enable_cost_based_join_reorder=false, enable_projection=true, runtime_filter_wait_time_ms=10000) */ l_orderkey, sum(l_extendedprice * (1 - l_discount)) as revenue, o_orderdate,