This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d46d8d0f6b5 [FLINK-31588][checkpoint] Correct the unaligned checkpoint
type based on the bytesPersistedDuringAlignment
add 26bd5fe390e [FLINK-31752] Fix SourceOperator numRecordsOut duplicate
bug
No new revisions were added by this update.
Summary of changes:
.../flink/connector/base/source/reader/SourceMetricsITCase.java | 4 ++++
.../flink/connector/base/source/reader/mocks/MockRecordEmitter.java | 1 +
.../flink/streaming/runtime/tasks/SourceOperatorStreamTask.java | 4 ----
3 files changed, 5 insertions(+), 4 deletions(-)
