This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3621b00 [FLINK-23345][python] Limits the version requests to 2.26.0
or above
add 1a7bc49 [FLINK-23848][connector/pulsar] Fix the consumer not found.
add 4e732ad [FLINK-23848][connector/pulsar] Make sure the topic would
only be sought once.
No new revisions were added by this update.
Summary of changes:
.../connector/pulsar/source/PulsarSource.java | 6 ++-
.../pulsar/source/PulsarSourceBuilder.java | 1 +
.../source/enumerator/PulsarSourceEnumerator.java | 56 ++++++++++++++++++++--
.../source/enumerator/SplitsAssignmentState.java | 20 ++++----
.../source/enumerator/cursor/CursorPosition.java | 9 ++++
.../source/enumerator/cursor/StartCursor.java | 15 +++---
.../cursor/start/MessageIdStartCursor.java | 3 +-
.../cursor/start/TimestampStartCursor.java | 3 +-
.../subscriber/impl/BasePulsarSubscriber.java | 8 ++--
.../subscriber/impl/TopicListSubscriber.java | 7 ++-
.../subscriber/impl/TopicPatternSubscriber.java | 10 ++--
.../split/PulsarOrderedPartitionSplitReader.java | 28 ++++++++++-
.../split/PulsarPartitionSplitReaderBase.java | 24 ----------
.../split/PulsarUnorderedPartitionSplitReader.java | 16 ++++---
.../pulsar/source/split/PulsarPartitionSplit.java | 23 ++-------
.../split/PulsarPartitionSplitSerializer.java | 28 +++++++----
.../source/split/PulsarPartitionSplitState.java | 1 -
.../pulsar/source/PulsarSourceITCase.java | 7 ---
.../PulsarSourceEnumStateSerializerTest.java | 2 -
.../enumerator/PulsarSourceEnumeratorTest.java | 12 ++---
.../enumerator/SplitsAssignmentStateTest.java | 9 +---
.../split/PulsarPartitionSplitSerializerTest.java | 2 -
.../source/split/PulsarPartitionSplitTest.java | 54 ---------------------
.../testutils/runtime/PulsarRuntimeOperator.java | 11 +++++
24 files changed, 179 insertions(+), 176 deletions(-)
delete mode 100644
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitTest.java
