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 07:14:30 UTC

[flink] branch master updated (b19a45de3e1 -> f8b3b33ce1c)

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 b19a45de3e1 [hotfix] Document connector_artifact shortcode
     add f8b3b33ce1c [FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase. (#21252)

No new revisions were added by this update.

Summary of changes:
 .../connector/pulsar/sink/PulsarSinkITCase.java    |  2 ++
 .../pulsar/testutils/function/ControlSource.java   | 41 ++++++++++++++++++----
 .../testutils/runtime/PulsarRuntimeOperator.java   |  4 +++
 3 files changed, 41 insertions(+), 6 deletions(-)