This is an automated email from the ASF dual-hosted git repository.
gaoyunhaii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 545fd7a [FLINK-23838][connectors/kafka] Implement FLIP-33 metrics for
KafkaSink
add e8ecf45 [FLINK-23430][runtime][checkpoint] Allows taking snapshots
for operator coordinators which all corresponding tasks finished
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/DefaultCheckpointPlan.java | 4 +--
.../flink/runtime/checkpoint/OperatorState.java | 4 +++
.../checkpoint/DefaultCheckpointPlanTest.java | 33 ++++++++++++++++++++++
3 files changed, 39 insertions(+), 2 deletions(-)
