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 cab4a98 [FLINK-23785][tests] Use unique operator names for metric
tests.
add b3dea50 [FLINK-23247][table-planner] Materialize time attribute
fields of regular join's inputs
No new revisions were added by this update.
Summary of changes:
.../planner/calcite/RelTimeIndicatorConverter.java | 24 +-
.../nodes/physical/common/CommonPhysicalJoin.scala | 17 +-
.../stream/StreamPhysicalIntervalJoinRule.scala | 56 +--
.../physical/stream/StreamPhysicalJoinRule.scala | 57 ++--
.../stream/StreamPhysicalTemporalJoinRule.scala | 26 +-
.../planner/plan/utils/IntervalJoinUtil.scala | 50 ++-
.../flink/table/planner/plan/utils/JoinUtil.scala | 89 ++++-
.../planner/plan/utils/TemporalJoinUtil.scala | 33 +-
.../plan/stream/sql/join/IntervalJoinTest.xml | 88 +++++
.../plan/stream/sql/join/WindowJoinTest.xml | 378 ++++++++++-----------
.../plan/stream/sql/join/IntervalJoinTest.scala | 6 +-
.../plan/stream/sql/join/WindowJoinTest.scala | 18 +
12 files changed, 526 insertions(+), 316 deletions(-)
