You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by go...@apache.org on 2023/01/30 01:54:58 UTC

[flink] branch master updated (02b09eac623 -> 916ff76b61a)

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(-)