This is an automated email from the ASF dual-hosted git repository.
RocMarshal pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from a47e4bf9b9e [FLINK-34673][test] Fix
SessionRelatedITCase#testTouchSession failure on GitHub Actions (#24826)
add 3fc308453a4 [FLINK-40172][table-runtime] Support processing-time early
fire on a row-time interval join
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/stream/StreamExecIntervalJoin.java | 6 +-
.../stream/StreamPhysicalIntervalJoinRule.java | 6 -
.../plan/hints/stream/EarlyFireJoinHintTest.java | 2 +-
.../plan/hints/stream/EarlyFireJoinHintTest.xml | 32 ++
.../join/interval/ProcTimeIntervalJoin.java | 4 +-
.../join/interval/RowTimeIntervalJoin.java | 6 +-
.../operators/join/interval/TimeIntervalJoin.java | 117 +++++-
.../join/interval/RowTimeIntervalJoinTest.java | 405 ++++++++++++++++++++-
.../interval/TimeIntervalStreamJoinTestBase.java | 17 +-
9 files changed, 554 insertions(+), 41 deletions(-)
