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 2022/05/21 15:19:35 UTC

[flink] branch master updated (e7d004d81c0 -> 18a967f8ad7)

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 e7d004d81c0 [hotfix][python][connector/pulsar] Improve PulsarDeserializationSchema.flink_type_info set execution_config default to None
     add 18a967f8ad7 [FLINK-27699][python][connector/pulsar] Support StopCursor.at_publish_time

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/datastream/connectors/pulsar.py  | 19 +++++++++++++++----
 .../pyflink/datastream/tests/test_connectors.py       |  7 ++++---
 2 files changed, 19 insertions(+), 7 deletions(-)