You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by di...@apache.org on 2023/05/24 02:41:41 UTC

[flink] branch master updated (fadde2a378a -> ae9e38ade27)

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from fadde2a378a [FLINK-32162] Only log error if an error occurred
     add ae9e38ade27 [FLINK-32056][Python][Connector/Pulsar] Add missing APIs in flink-connector-pulsar v4.0.0

No new revisions were added by this update.

Summary of changes:
 .../reference/pyflink.datastream/connectors.rst    |   1 +
 .../pyflink/datastream/connectors/pulsar.py        | 161 ++++++++++++++++++---
 .../datastream/connectors/tests/test_pulsar.py     |  41 +++++-
 3 files changed, 181 insertions(+), 22 deletions(-)