This is an automated email from the ASF dual-hosted git repository.
leonard pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from df0363d [FLINK-26708] TimestampsAndWatermarksOperator should not
propagate WatermarkStatus
new 96c64a1 [hotfix][connector/common] Fix typo of variable in
SourceOperator
new 6504711 [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 | 140 ++++++++++++++++++++-
.../connector/kafka/source/KafkaSourceITCase.java | 63 ++++++++++
.../streaming/api/operators/SourceOperator.java | 55 ++++++--
.../source/SourceOperatorEventTimeTest.java | 121 +++++++-----------
.../operators/source/TestingSourceOperator.java | 57 +++++++++
8 files changed, 363 insertions(+), 89 deletions(-)
