This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 5e02d64bf01 [FLINK-38542][checkpoint] Randomize
UNALIGNED_ALLOW_ON_RECOVERY for testing
add eb3357741b7 [hotfix] Set mailboxExecutor in AbstractStreamOperator
constructor if available
add a4423b18d32 [FLINK-38810] Pull WM processing up from
KeyedCoProcessOperatorWithWatermarkDelay
add 4d72763053c [FLINK-38810] Enable splittable timers in Interval Join
No new revisions were added by this update.
Summary of changes:
.../flink/api/common/functions/RichFunction.java | 27 ++++++
.../api/operators/AbstractStreamOperator.java | 89 +++++++++++++++++++-
.../api/operators/AbstractStreamOperatorV2.java | 10 ++-
.../api/operators/AbstractUdfStreamOperator.java | 17 +++-
.../api/operators/co/KeyedCoProcessOperator.java | 8 +-
.../AbstractUdfStreamOperatorLifecycleTest.java | 4 +-
.../KeyedCoProcessOperatorWithWatermarkDelay.java | 37 ++-------
.../operators/join/interval/TimeIntervalJoin.java | 4 +
.../join/interval/RowTimeIntervalJoinTest.java | 96 ++++++++++++++++++++++
9 files changed, 253 insertions(+), 39 deletions(-)
