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 2022/08/10 02:27:48 UTC

[flink] branch master updated (10acb641a03 -> 320f4cd5e5f)

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 10acb641a03 [FLINK-26929][table-runtime] Introduce adaptive hash join strategy for batch hash join (#20365)
     add 320f4cd5e5f [FLINK-28821][table-planner] Adjust join cost for dpp query pattern which could help more plans use dpp

No new revisions were added by this update.

Summary of changes:
 .../batch/DynamicPartitionPruningRule.java         | 304 +++---------------
 .../utils/DynamicPartitionPruningUtils.java        | 349 +++++++++++++++++++++
 .../planner/plan/metadata/FlinkRelMdRowCount.scala |  15 +-
 .../batch/DynamicPartitionPruningRuleTest.java     |  79 +++++
 .../batch/DynamicPartitionPruningRuleTest.xml      |  87 ++++-
 5 files changed, 569 insertions(+), 265 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java