This is an automated email from the ASF dual-hosted git repository.
lindong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d88f39c4486 [FLINK-31405][test] Refactor tests to git rid of timeout
of CompletableFuture assertions.
add 1d33773e6b7 [FLINK-25509][connector-base] Add RecordEvaluator to
dynamically stop source based on de-serialized records
No new revisions were added by this update.
Summary of changes:
.../base/source/reader/RecordEvaluator.java | 21 ++---
.../SingleThreadMultiplexSourceReaderBase.java | 24 ++++++
.../base/source/reader/SourceReaderBase.java | 96 +++++++++++++++++++++-
.../{AddSplitsTask.java => RemoveSplitsTask.java} | 39 ++++++---
.../reader/fetcher/SingleThreadFetcherManager.java | 8 ++
.../base/source/reader/fetcher/SplitFetcher.java | 20 +++++
.../source/reader/fetcher/SplitFetcherManager.java | 2 +
.../source/reader/splitreader/SplitReader.java | 4 +
.../{SplitsAddition.java => SplitsRemoval.java} | 21 +++--
.../base/source/reader/SourceReaderBaseTest.java | 51 ++++++++++++
.../base/source/reader/mocks/MockSourceReader.java | 16 ++++
.../base/source/reader/mocks/MockSplitReader.java | 19 ++++-
12 files changed, 289 insertions(+), 32 deletions(-)
copy
flink-core/src/main/java/org/apache/flink/api/common/distributions/RangeBoundaries.java
=>
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/RecordEvaluator.java
(60%)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/{AddSplitsTask.java
=> RemoveSplitsTask.java} (55%)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/{SplitsAddition.java
=> SplitsRemoval.java} (60%)
