This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cba124a [FLINK-19933][DataStream] Execute and collect with limit
fails on bounded datastream jobs
new 36498a0 [FLINK-19265][core] Add to source coordinator built-in
methods to signal "no more splits".
new 0e281f7 [FLINK-20049][core] Add built-in method to request split in
source API.
new 92ca579 [hotfix][connector files] Remove empty default method
override in FileSourceReader
new 98400bb [hotfix] Close File FormatReaders also when the source reader
is closed before end of split.
new a475f57 [FLINK-20051][connector kafka] Ensure
KafkaPartitionSplitRecords returned on consumer wakeup is properly initializes
The 5 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:
.../base/source/reader/SourceReaderBase.java | 17 ++++----
.../base/source/reader/SourceReaderBaseTest.java | 3 +-
.../source/reader/mocks/MockSplitEnumerator.java | 14 +++----
.../src/impl/ContinuousFileSplitEnumerator.java | 17 ++++----
.../connector/file/src/impl/FileSourceReader.java | 12 +-----
.../file/src/impl/FileSourceSplitReader.java | 6 ++-
.../file/src/impl/StaticFileSplitEnumerator.java | 45 +++++++++-------------
.../file/src/FileSourceHeavyThroughputTest.java | 6 ++-
.../hive/ContinuousHiveSplitEnumerator.java | 16 ++++----
.../source/enumerator/KafkaSourceEnumerator.java | 10 ++---
.../source/reader/KafkaPartitionSplitReader.java | 1 +
.../kafka/source/reader/KafkaSourceReaderTest.java | 5 ++-
.../flink/api/connector/source/SourceReader.java | 14 ++++++-
.../api/connector/source/SourceReaderContext.java | 7 ++++
.../api/connector/source/SplitEnumerator.java | 24 ++++++++++--
.../connector/source/SplitEnumeratorContext.java | 8 ++++
.../source/lib/util/IteratorSourceEnumerator.java | 14 ++-----
.../source/lib/util/IteratorSourceReader.java | 26 ++++++-------
.../connector/source/mocks/MockSourceReader.java | 20 ++++------
.../source/mocks/MockSplitEnumerator.java | 5 +++
.../source/mocks/MockSplitEnumeratorContext.java | 3 ++
.../source/mocks/TestingReaderContext.java | 3 ++
.../source/coordinator/SourceCoordinator.java | 8 +++-
.../coordinator/SourceCoordinatorContext.java | 14 +++++++
.../runtime}/source/event/NoMoreSplitsEvent.java | 6 +--
.../runtime}/source/event/RequestSplitEvent.java | 6 +--
.../streaming/api/operators/SourceOperator.java | 9 +++++
.../source/SourceOperatorEventTimeTest.java | 3 +-
.../runtime/tasks/MultipleInputStreamTaskTest.java | 6 +--
.../checkpointing/UnalignedCheckpointITCase.java | 8 ++--
30 files changed, 198 insertions(+), 138 deletions(-)
rename {flink-core/src/main/java/org/apache/flink/api/connector =>
flink-runtime/src/main/java/org/apache/flink/runtime}/source/event/NoMoreSplitsEvent.java
(87%)
rename {flink-core/src/main/java/org/apache/flink/api/connector =>
flink-runtime/src/main/java/org/apache/flink/runtime}/source/event/RequestSplitEvent.java
(92%)
