This is an automated email from the ASF dual-hosted git repository.
junrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 65db14d9e35 [FLINK-37090][e2e] add adaptive broadcast join to e2e
tpc-ds tests. (#25954)
65db14d9e35 is described below
commit 65db14d9e3534b26c71a6a430f15c24b07ae286a
Author: Xia Sun <xingbe...@gmail.com>
AuthorDate: Thu Jan 16 12:04:01 2025 +0800
[FLINK-37090][e2e] add adaptive broadcast join to e2e tpc-ds tests. (#25954)
---
flink-end-to-end-tests/test-scripts/test_tpcds.sh | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-end-to-end-tests/test-scripts/test_tpcds.sh
b/flink-end-to-end-tests/test-scripts/test_tpcds.sh
index c46db4b4396..90f47fb1e29 100755
--- a/flink-end-to-end-tests/test-scripts/test_tpcds.sh
+++ b/flink-end-to-end-tests/test-scripts/test_tpcds.sh
@@ -72,6 +72,8 @@ function run_test() {
set_config_key "execution.batch.speculative.block-slow-node-duration"
"0s"
set_config_key "slow-task-detector.execution-time.baseline-ratio" "0.0"
set_config_key
"slow-task-detector.execution-time.baseline-lower-bound" "0s"
+ set_config_key "table.optimizer.adaptive-broadcast-join.strategy"
"auto"
+ set_config_key "table.optimizer.join.broadcast-threshold" "10485760L"
else
echo "ERROR: Scheduler ${scheduler} is unsupported for tpcds test.
Aborting..."
exit 1
