You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by dw...@apache.org on 2025/07/02 14:21:17 UTC

(flink) branch master updated (5497b714347 -> 4aa434fbf46)

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

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


    from 5497b714347 [FLINK-38030][table-planner] Fix cast exception for TableLineageDatasetImpl when the catalog is not a AbstractCatalog (#26727)
     add 4aa434fbf46 [FLINK-38037][table] Configure hashDistribution with commonJoinKey (#26734)

No new revisions were added by this update.

Summary of changes:
 .../physical/stream/StreamPhysicalMultiJoin.java   |  49 +++-
 .../stream/StreamPhysicalMultiJoinRule.java        |  58 +++--
 .../planner/plan/stream/sql/MultiJoinTest.xml      | 275 +++++++++++++--------
 ...our-way-complex-updating-join-with-restore.json | 152 +++++++++---
 .../savepoint/_metadata                            | Bin 35983 -> 35162 bytes
 ...r-way-join-no-common-join-key-with-restore.json | 181 +++++++++++---
 .../savepoint/_metadata                            | Bin 41692 -> 41248 bytes
 .../plan/three-way-inner-join-with-restore.json    | 130 +++++++---
 .../savepoint/_metadata                            | Bin 21336 -> 21326 bytes
 ...way-join-with-time-attributes-with-restore.json | 127 +++++++---
 .../savepoint/_metadata                            | Bin 25437 -> 24946 bytes
 .../three-way-left-outer-join-with-restore.json    | 140 +++++++----
 .../savepoint/_metadata                            | Bin 21577 -> 21759 bytes
 13 files changed, 800 insertions(+), 312 deletions(-)