This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from a3905929fb7 [hotfix][docs] Fix grammer
add d03c334b7ac [FLINK-29512][streaming] Align the checkpointId of
recovered CommittableWithLinages with the CommittableSummary
No new revisions were added by this update.
Summary of changes:
.../CommittableCollectorSerializer.java | 30 ++++++++++++++++++---
.../operators/sink/CommitterOperatorTest.java | 14 +++++++---
.../CommittableCollectorSerializerTest.java | 31 ++++++++++++++++++++--
3 files changed, 66 insertions(+), 9 deletions(-)