You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ti...@apache.org on 2022/11/08 06:53:32 UTC
[flink] branch master updated (54679fd7ddb -> 27d42b2e599)
This is an automated email from the ASF dual-hosted git repository.
tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 54679fd7ddb [FLINK-29628][S3][Filesystem] Bump aws-java-sdk-s3 from 1.11.171 to 1.12.319
add 27d42b2e599 [FLINK-28083][Connector/Pulsar] PulsarSource work with object-reusing DeserializationSchema. (#21205)
No new revisions were added by this update.
Summary of changes:
.../source/reader/PulsarSourceReaderFactory.java | 23 +++----
.../source/reader/emitter/PulsarRecordEmitter.java | 63 ++++++++++++++++--
.../reader/fetcher/PulsarFetcherManagerBase.java | 27 ++++----
.../fetcher/PulsarOrderedFetcherManager.java | 18 +++---
.../fetcher/PulsarUnorderedFetcherManager.java | 14 ++--
.../source/reader/message/PulsarMessage.java | 74 ----------------------
.../reader/message/PulsarMessageCollector.java | 60 ------------------
.../reader/source/PulsarOrderedSourceReader.java | 15 +++--
.../reader/source/PulsarSourceReaderBase.java | 18 ++----
.../reader/source/PulsarUnorderedSourceReader.java | 13 ++--
.../split/PulsarOrderedPartitionSplitReader.java | 13 +---
.../split/PulsarPartitionSplitReaderBase.java | 33 +++-------
.../split/PulsarUnorderedPartitionSplitReader.java | 11 +---
.../source/enumerator/cursor/StopCursorTest.java | 17 ++---
.../PulsarOrderedPartitionSplitReaderTest.java | 8 +--
.../split/PulsarPartitionSplitReaderTestBase.java | 74 ++++++++++------------
16 files changed, 175 insertions(+), 306 deletions(-)
delete mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/message/PulsarMessage.java
delete mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/message/PulsarMessageCollector.java