This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c41f169 [FLINK-27024][build] Cleanup surefire configuration
add 71a9f31 [FLINK-26645][Connector/pulsar] Support subscribe only one
topic partition.
No new revisions were added by this update.
Summary of changes:
.../sink/writer/topic/TopicMetadataListener.java | 8 +-
.../subscriber/impl/BasePulsarSubscriber.java | 23 +++--
.../subscriber/impl/TopicListSubscriber.java | 56 +++++++++---
.../source/enumerator/topic/TopicNameUtils.java | 6 +-
.../writer/topic/TopicMetadataListenerTest.java | 4 +-
.../subscriber/PulsarSubscriberTest.java | 99 +++++++++++++++++-----
.../testutils/runtime/PulsarRuntimeOperator.java | 2 +-
7 files changed, 139 insertions(+), 59 deletions(-)
