This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 092647c [FLINK-26063][runtime] Set current key before polling next PQ
element
add c81fff6 [hotfix][connector/common] Fix typo of variable in
SourceOperator
add b959371 [FLINK-26018][connector/common] Create per-split output on
split addition in SourceOperator
No new revisions were added by this update.
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(-)
