This is an automated email from the ASF dual-hosted git repository.
tison pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
from b32d9ff3a40 [hotfix][Azure][python] Upgrade to macOS-latest
new 8ef5d76cf6e [FLINK-28934][Connector/pulsar] Fix split assignment in
different Pulsar subscriptions.
new 7c88a9ba0d5 [FLINK-27388][Connector/pulsar] Change the topic setup
logic in Pulsar runtime operator.
new 417be6a96c3 [FLINK-28084][Connector/pulsar] Disable retry and delete
reconsume logic on PulsarUnorderedPartitionSplitReader.
new e12e0386a1f [FLINK-27611][Connector/pulsar] Fix
ConcurrentModificationException during checkpoint on Pulsar unordered reader.
new 779a814fcfa [FLINK-27400][Connector/pulsar] Filter system topics for
Pulsar connector.
new 596eb9d9349 [FLINK-28934][Connector/pulsar] Drop checkpoint id for
unordered source.
The 6 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:
.../pulsar/common/schema/PulsarSchema.java | 12 +-
.../pulsar/common/utils/PulsarSerdeUtils.java | 5 +-
.../connector/pulsar/source/PulsarSource.java | 12 +-
.../source/enumerator/PulsarSourceEnumState.java | 54 +-----
.../PulsarSourceEnumStateSerializer.java | 51 ++---
.../source/enumerator/PulsarSourceEnumerator.java | 52 +++++-
.../assigner/NonSharedSplitAssigner.java | 100 +++++-----
.../enumerator/assigner/SharedSplitAssigner.java | 108 +++--------
.../source/enumerator/assigner/SplitAssigner.java | 7 +-
.../enumerator/assigner/SplitAssignerBase.java | 102 ++++++++++
.../enumerator/assigner/SplitAssignerFactory.java | 43 ++---
.../source/enumerator/cursor/CursorPosition.java | 6 +
.../subscriber/impl/TopicPatternSubscriber.java | 3 +
.../source/enumerator/topic/TopicNameUtils.java | 52 +++++-
.../fetcher/PulsarUnorderedFetcherManager.java | 16 +-
.../reader/source/PulsarUnorderedSourceReader.java | 65 +++++--
.../split/PulsarPartitionSplitReaderBase.java | 15 +-
.../split/PulsarUnorderedPartitionSplitReader.java | 21 +--
.../pulsar/source/PulsarSourceITCase.java | 15 +-
.../PulsarSourceEnumStateSerializerTest.java | 24 +--
.../enumerator/PulsarSourceEnumeratorTest.java | 205 +++++++++------------
.../assigner/NonSharedSplitAssignerTest.java | 64 ++++---
.../assigner/SharedSplitAssignerTest.java | 43 ++++-
.../enumerator/assigner/SplitAssignerTestBase.java | 55 ++++--
.../enumerator/topic/TopicNameUtilsTest.java | 25 +++
.../testutils/runtime/PulsarRuntimeOperator.java | 149 +++++----------
.../runtime/container/PulsarContainerRuntime.java | 56 ++++--
.../testutils/runtime/mock/PulsarMockRuntime.java | 5 +-
28 files changed, 719 insertions(+), 646 deletions(-)
create mode 100644
flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssignerBase.java
