This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 5c68f69362 [improvement](config) set enable_local_exchange default
value to true (#13292)
5c68f69362 is described below
commit 5c68f6936250fa8bed1560461cc0059cbccd3795
Author: Pxl <[email protected]>
AuthorDate: Wed Oct 12 09:07:24 2022 +0800
[improvement](config) set enable_local_exchange default value to true
(#13292)
---
be/src/vec/sink/vdata_stream_sender.h | 2 +-
fe/fe-core/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 f3b561c625..049de75d0e 100644
--- a/be/src/vec/sink/vdata_stream_sender.h
+++ b/be/src/vec/sink/vdata_stream_sender.h
@@ -309,7 +309,7 @@ private:
PBlock _ch_pb_block1;
PBlock _ch_pb_block2;
- bool _enable_local_exchange = false;
+ bool _enable_local_exchange = true;
};
template <typename Channels>
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 ee1a5e7627..c079cf7041 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 01561b56cc..0bd7a59a0a 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,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
