This is an automated email from the ASF dual-hosted git repository.
zakelly pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from dbd21cf56af [FLINK-36815][API] Introduce a NonPartitionedContext
parameter in Open method of UserFunction for DSv2
add 82031921de0 [FLINK-36823][Checkpointing] Drain state requests after
the user function perform snapshotState (#25715)
No new revisions were added by this update.
Summary of changes:
.../asyncprocessing/operators/AbstractAsyncStateStreamOperator.java | 6 ++++++
.../operators/AbstractAsyncStateUdfStreamOperator.java | 2 ++
2 files changed, 8 insertions(+)
