This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 29243e0 [FLINK-26634][docs-zh] Update Chinese version of
Elasticsearch connector docs
add 5a5490a [refactor][streaming] Migrate Source(Operator)StreamTaskTest
to JUnit5 and assertj
add d5d859e [FLINK-25256][streaming] Externally induced sources replay
barriers received over RPC instead of inventing them out of thin air.
add 42e9785 [FLINK-25256][streaming] Clarify the contract of
ExternallyInducedSource(Reader).
No new revisions were added by this update.
Summary of changes:
.../source/ExternallyInducedSourceReader.java | 12 +-
.../api/checkpoint/ExternallyInducedSource.java | 4 +-
.../io/StreamTaskExternallyInducedSourceInput.java | 24 +++
.../runtime/tasks/SourceOperatorStreamTask.java | 187 +++++++++++++++++----
.../tasks/SourceOperatorStreamTaskTest.java | 134 +++++++++++----
.../runtime/tasks/SourceStreamTaskTest.java | 93 +++++-----
.../runtime/tasks/SourceStreamTaskTestBase.java | 23 ++-
7 files changed, 344 insertions(+), 133 deletions(-)
