org.apache.spark.sql.execution.ReduceNumShufflePartitionsSuite

determining the number of reducers: aggregate operator

determining the number of reducers: aggregate operator(minNumPostShufflePartitions: 5)

determining the number of reducers: complex query 1

determining the number of reducers: complex query 1(minNumPostShufflePartitions: 5)

determining the number of reducers: complex query 2

determining the number of reducers: complex query 2(minNumPostShufflePartitions: 5)

determining the number of reducers: join operator

determining the number of reducers: join operator(minNumPostShufflePartitions: 5)

determining the number of reducers: plan already partitioned

determining the number of reducers: plan already partitioned(minNumPostShufflePartitions: 5)

Do not reduce the number of shuffle partition for repartition

SPARK-24705 adaptive query execution works correctly when exchange reuse enabled

test estimatePartitionStartIndices - 1 Exchange

test estimatePartitionStartIndices - 2 Exchanges

test estimatePartitionStartIndices and enforce minimal number of reducers

Union two datasets with different pre-shuffle partition number