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 ed6de585481 [FLINK-37092][e2e] Add adaptive skewed join optimization
to e2e tpc-ds tests
ed6de585481 is described below
commit ed6de5854816654db3487ad1d6ec8b34b451c3cf
Author: noorall <863485...@qq.com>
AuthorDate: Wed Jan 15 09:58:12 2025 +0800
[FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-ds tests
This closes #25985
---
flink-end-to-end-tests/test-scripts/test_tpcds.sh | 3 +++
1 file changed, 3 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 90f47fb1e29..800d70490f2 100755
--- a/flink-end-to-end-tests/test-scripts/test_tpcds.sh
+++ b/flink-end-to-end-tests/test-scripts/test_tpcds.sh
@@ -74,6 +74,9 @@ function run_test() {
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"
+ set_config_key "table.optimizer.skewed-join-optimization.strategy"
"auto"
+ set_config_key
"table.optimizer.skewed-join-optimization.skewed-threshold" "100kb"
+ set_config_key
"table.optimizer.skewed-join-optimization.skewed-factor" "1.0"
else
echo "ERROR: Scheduler ${scheduler} is unsupported for tpcds test.
Aborting..."
exit 1
