This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3fed74d [FLINK-26799][state/changelog] fix seek condition in
StateChangeFormat#read
new 28228ac [hotfix][connector/common] Fix typo of variable in
SourceOperator
new c71582d [FLINK-26018][connector/common] Create per-split output on
split addition in SourceOperator
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-connectors/flink-connector-base/pom.xml | 8 ++
.../base/source/reader/SourceReaderBase.java | 3 +
.../source/reader/splitreader/SplitReader.java | 5 +
.../base/source/reader/SourceReaderBaseTest.java | 130 +++++++++++++++++++++
.../connector/kafka/source/KafkaSourceITCase.java | 64 ++++++++++
.../streaming/api/operators/SourceOperator.java | 56 ++++++---
.../source/SourceOperatorEventTimeTest.java | 121 ++++++++-----------
.../operators/source/TestingSourceOperator.java | 58 +++++++++
8 files changed, 356 insertions(+), 89 deletions(-)
