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

Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/01/03 13:00:37 UTC

[pulsar] branch master updated (dcaa1d3 -> 5c58ff4)

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

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


    from dcaa1d3  fix  2 copies of 3bookie and stop 2 booksie after production. After the entire bookie is restored, it can be produced at this time, and the produced data cannot be consumed normally. Restarting the broker can resume normal (#5965)
     add 5c58ff4  [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process (#5900)

No new revisions were added by this update.

Summary of changes:
 .../connectors/pulsar/CachedPulsarClient.java      | 106 +++++++++++++++++++++
 .../connectors/pulsar/FlinkPulsarProducer.java     |   2 +-
 .../connectors/pulsar/PulsarConsumerSource.java    |   7 +-
 .../connectors/pulsar/CachedPulsarClientTest.java  | 103 ++++++++++++++++++++
 .../pulsar/PulsarConsumerSourceTests.java          |   2 +-
 5 files changed, 215 insertions(+), 5 deletions(-)
 create mode 100644 pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClient.java
 create mode 100644 pulsar-flink/src/test/java/org/apache/flink/streaming/connectors/pulsar/CachedPulsarClientTest.java