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 2fe318b9141 [FLINK-38761][runtime] Support archiving applications
add a335e9f2e01 [FLINK-38923] Pass config to useInterruptibleTimers()
No new revisions were added by this update.
Summary of changes:
.../apache/flink/api/common/functions/RichFunction.java | 3 ++-
.../java/org/apache/flink/cep/operator/CepOperator.java | 3 ++-
.../streaming/api/operators/AbstractStreamOperator.java | 9 +++++----
.../streaming/api/operators/AbstractStreamOperatorV2.java | 5 +++--
.../streaming/api/operators/AbstractUdfStreamOperator.java | 5 +++--
.../operators/AbstractUdfStreamOperatorLifecycleTest.java | 3 ++-
.../UnalignedCheckpointsInterruptibleTimersTest.java | 3 ++-
.../runtime/operators/AsyncStateTableStreamOperator.java | 3 ++-
.../flink/table/runtime/operators/TableStreamOperator.java | 3 ++-
.../runtime/operators/join/interval/TimeIntervalJoin.java | 4 +++-
.../BaseTwoInputStreamOperatorWithStateRetention.java | 3 ++-
.../runtime/operators/sort/BaseTemporalSortOperator.java | 3 ++-
.../window/groupwindow/operator/WindowOperator.java | 3 ++-
.../table/runtime/operators/aggregate/HashAggTest.java | 14 +++++++++++++-
.../operators/aggregate/SumHashAggTestOperator.java | 10 +++++++++-
15 files changed, 54 insertions(+), 20 deletions(-)
