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

Posted to commits@flink.apache.org by ja...@apache.org on 2022/08/19 04:07:12 UTC

[flink] branch master updated (e967a7b54da -> d9516238cef)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from e967a7b54da [FLINK-28965][hive] Partition shouldn't be created if no data is generated for dynamic partition
     add d9516238cef [FLINK-28917][table-runtime] Add SQL test for adaptive hash join

No new revisions were added by this update.

Summary of changes:
 .../planner/codegen/LongHashJoinGenerator.scala    |   2 +
 .../batch/sql/join/AdaptiveHashJoinITCase.java     | 186 +++++++++++++++++++++
 .../runtime/hashtable/BaseHybridHashTable.java     |  29 +++-
 .../runtime/hashtable/BinaryHashBucketArea.java    |   2 +-
 .../runtime/hashtable/BinaryHashPartition.java     |   2 +-
 .../runtime/operators/join/HashJoinOperator.java   |   3 +
 .../operators/join/SortMergeJoinFunction.java      |  29 +++-
 .../operators/join/SortMergeJoinOperator.java      |   1 +
 8 files changed, 244 insertions(+), 10 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/join/AdaptiveHashJoinITCase.java