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/11 13:10:21 UTC
[flink] branch master updated (f8b3b33ce1c -> 9c970b917bf)

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 f8b3b33ce1c [FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase. (#21252)
     add 9c970b917bf [FLINK-26027][Connector/Pulsar] Expose Pulsar producer metrics and add FLIP-33 sink metrics. (#21249)

No new revisions were added by this update.

Summary of changes:
 .../generated/pulsar_sink_configuration.html       |  6 ++
 .../generated/pulsar_source_configuration.html     |  6 ++
 .../pulsar/common/metrics/MetricNames.java         | 63 ++++++++++++++++
 .../common/metrics/ProducerMetricsInterceptor.java | 67 +++++++++++++++++
 .../connector/pulsar/sink/PulsarSinkOptions.java   | 14 ++++
 .../pulsar/sink/config/SinkConfiguration.java      | 16 +++-
 .../connector/pulsar/sink/writer/PulsarWriter.java |  6 +-
 .../sink/writer/topic/TopicProducerRegister.java   | 86 +++++++++++++++++++++-
 .../pulsar/source/PulsarSourceOptions.java         | 14 ++++
 .../pulsar/source/config/SourceConfiguration.java  | 16 +++-
 .../source/enumerator/PulsarSourceEnumerator.java  |  8 ++
 .../source/enumerator/assigner/SplitAssigner.java  |  3 +
 .../enumerator/assigner/SplitAssignerBase.java     |  5 ++
 .../source/reader/PulsarSourceReaderFactory.java   |  6 +-
 .../split/PulsarOrderedPartitionSplitReader.java   |  6 +-
 .../split/PulsarPartitionSplitReaderBase.java      | 66 ++++++++++++++++-
 .../split/PulsarUnorderedPartitionSplitReader.java |  4 +-
 .../connector/pulsar/sink/PulsarSinkITCase.java    |  4 +-
 .../writer/topic/TopicProducerRegisterTest.java    |  7 +-
 .../source/enumerator/cursor/StopCursorTest.java   |  6 +-
 .../split/PulsarPartitionSplitReaderTestBase.java  | 12 ++-
 .../testutils/sink/PulsarSinkTestSuiteBase.java    | 37 ----------
 .../flink/tests/util/pulsar/PulsarSinkE2ECase.java |  4 +-
 .../metrics/groups/UnregisteredMetricsGroup.java   | 35 +++++++++
 24 files changed, 438 insertions(+), 59 deletions(-)
 create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/MetricNames.java
 create mode 100644 flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/ProducerMetricsInterceptor.java
 delete mode 100644 flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/sink/PulsarSinkTestSuiteBase.java