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
