This is an automated email from the ASF dual-hosted git repository. godfrey pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
from 02b09eac623 [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks. add 916ff76b61a [FLINK-30814][table-planner] Fix maxParallelism is not forced to 1 after global partitioner No new revisions were added by this update. Summary of changes: .../planner/plan/nodes/exec/ExecNodeBase.java | 15 +- .../plan/nodes/exec/batch/BatchExecLimit.java | 4 +- .../nodes/exec/batch/BatchExecNestedLoopJoin.java | 3 +- .../plan/nodes/exec/batch/BatchExecRank.java | 4 +- .../nodes/exec/batch/BatchExecScriptTransform.java | 3 +- .../plan/nodes/exec/batch/BatchExecSort.java | 4 +- .../nodes/physical/batch/BatchPhysicalLimit.scala | 8 +- .../physical/batch/BatchPhysicalSortLimit.scala | 12 +- .../runtime/batch/ParallelismSettingTest.java | 255 +++++++++++++++++++-- 9 files changed, 285 insertions(+), 23 deletions(-)