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

Posted to commits@pulsar.apache.org by eo...@apache.org on 2021/08/10 06:21:57 UTC

[pulsar] branch master updated (b7e027b -> 31231d6)

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

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


    from b7e027b  Fix: Cast exception occurs if function/source/sink type is ByteBuffer (#11611)
     add 31231d6  Use ZK persistent watches (#11198)

No new revisions were added by this update.

Summary of changes:
 .../service/web/MetadataStoreCacheLoaderTest.java  |   16 +-
 .../metadata/impl/PulsarZooKeeperClient.java       | 1554 ++++++++++++++++++++
 .../pulsar/metadata/impl/ZKMetadataStore.java      |   64 +-
 .../pulsar/metadata/impl/ZKSessionWatcher.java     |    4 +
 .../apache/pulsar/metadata/MetadataCacheTest.java  |    5 +-
 .../apache/pulsar/metadata/MetadataStoreTest.java  |    1 +
 .../java/org/apache/zookeeper/MockZooKeeper.java   |   64 +
 .../org/apache/zookeeper/MockZooKeeperSession.java |   21 +
 8 files changed, 1708 insertions(+), 21 deletions(-)
 create mode 100644 pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java