From c30aca754ffa61bc6943ac038dc8fb18007f857e Mon Sep 17 00:00:00 2001 From: Matteo Merli Date: Fri, 17 Nov 2023 15:38:23 -0800 Subject: [PATCH 1/2] Update Pulsar version to 3.0.1.6 --- pulsar-metadatastore-oxia/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-metadatastore-oxia/pom.xml b/pulsar-metadatastore-oxia/pom.xml index 3592678f..3ae735e4 100644 --- a/pulsar-metadatastore-oxia/pom.xml +++ b/pulsar-metadatastore-oxia/pom.xml @@ -36,7 +36,7 @@ UTF-8 io.streamnative.pulsarmetadatastoreoxia.shaded - 2.11.0.3 + 3.0.1.6 10.3.3 7.7.0 From c0754a6024ed2c26b51d65564835fbaf1fea1db9 Mon Sep 17 00:00:00 2001 From: Matteo Merli Date: Mon, 15 Jan 2024 20:21:00 -0800 Subject: [PATCH 2/2] Fixed compile issue --- pulsar-metadatastore-oxia/pom.xml | 8 ++++---- .../pulsarmetadatastoreoxia/OxiaMetadataStore.java | 2 ++ 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/pulsar-metadatastore-oxia/pom.xml b/pulsar-metadatastore-oxia/pom.xml index 3ae735e4..5138ae2e 100644 --- a/pulsar-metadatastore-oxia/pom.xml +++ b/pulsar-metadatastore-oxia/pom.xml @@ -36,7 +36,7 @@ UTF-8 io.streamnative.pulsarmetadatastoreoxia.shaded - 3.0.1.6 + 3.0.2 10.3.3 7.7.0 @@ -61,7 +61,7 @@ ${project.version} - io.streamnative + org.apache.pulsar pulsar-metadata ${pulsar.version} provided @@ -79,13 +79,13 @@ test - io.streamnative + org.apache.pulsar buildtools ${pulsar.version} test - io.streamnative + org.apache.pulsar pulsar-metadata ${pulsar.version} test-jar diff --git a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java index 7466c019..953f40af 100644 --- a/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java +++ b/pulsar-metadatastore-oxia/src/main/java/io/streamnative/pulsarmetadatastoreoxia/OxiaMetadataStore.java @@ -57,6 +57,8 @@ public class OxiaMetadataStore extends AbstractMetadataStore { @NonNull MetadataStoreConfig metadataStoreConfig, boolean enableSessionWatcher) throws Exception { + super("oxia-metadata"); + var linger = metadataStoreConfig.getBatchingMaxDelayMillis(); if (!metadataStoreConfig.isBatchingEnabled()) { linger = 0;