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(-)
