[FLINK-37092][e2e] Add adaptive skewed join optimization to e2e tpc-d…

…s tests This closes apache#25985
twalthr · Jan 16, 2025 · ed6de58 · ed6de58
1 parent b3e7f9b
commit ed6de58
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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