You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2026/07/22 10:02:44 UTC
(pulsar) 09/15: [improve][meta] Upgrade Oxia client to 0.9.4 (#26193)
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-4.2
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit dc18bd0230f522d023a5172e75d1060807c55206
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Wed Jul 15 00:55:14 2026 -0700
[improve][meta] Upgrade Oxia client to 0.9.4 (#26193)
(cherry picked from commit 0ae4d94689d1f01988803c34261789f098da81a6)
---
distribution/server/src/assemble/LICENSE.bin.txt | 4 ++--
pom.xml | 2 +-
.../java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java | 5 -----
.../apache/pulsar/metadata/impl/oxia/OxiaMetadataStoreProvider.java | 3 ---
4 files changed, 3 insertions(+), 11 deletions(-)
diff --git a/distribution/server/src/assemble/LICENSE.bin.txt b/distribution/server/src/assemble/LICENSE.bin.txt
index 0b3903892b13..99bc47490268 100644
--- a/distribution/server/src/assemble/LICENSE.bin.txt
+++ b/distribution/server/src/assemble/LICENSE.bin.txt
@@ -498,8 +498,8 @@ The Apache Software License, Version 2.0
* Prometheus
- io.prometheus-simpleclient_httpserver-0.16.0.jar
* Oxia
- - io.github.oxia-db-oxia-client-api-0.8.0.jar
- - io.github.oxia-db-oxia-client-0.8.0.jar
+ - io.github.oxia-db-oxia-client-api-0.9.4.jar
+ - io.github.oxia-db-oxia-client-0.9.4.jar
* OpenHFT
- net.openhft-zero-allocation-hashing-0.16.jar
* Java JSON WebTokens
diff --git a/pom.xml b/pom.xml
index 3e9aaadabc8c..359ad4ac84cc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -296,7 +296,7 @@ flexible messaging model and an intuitive client API.</description>
<apache-http-client.version>4.5.14</apache-http-client.version>
<apache-httpcomponents.version>4.4.16</apache-httpcomponents.version>
<jetcd.version>0.7.7</jetcd.version>
- <oxia.version>0.8.0</oxia.version>
+ <oxia.version>0.9.4</oxia.version>
<oxia-testcontainers.version>0.7.4</oxia-testcontainers.version>
<snakeyaml.version>2.0</snakeyaml.version>
<ant.version>1.10.12</ant.version>
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java
index 675f3dbf1ad6..fbf5b75e7068 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java
@@ -80,10 +80,6 @@ public class OxiaMetadataStore extends AbstractMetadataStore {
super("oxia-metadata", Objects.requireNonNull(metadataStoreConfig).getOpenTelemetry(),
metadataStoreConfig.getNodeSizeStats(), metadataStoreConfig.getNumSerDesThreads());
- var linger = metadataStoreConfig.getBatchingMaxDelayMillis();
- if (!metadataStoreConfig.isBatchingEnabled()) {
- linger = 0;
- }
synchronizer = Optional.ofNullable(metadataStoreConfig.getSynchronizer());
identity = UUID.randomUUID().toString();
OxiaClientBuilder oxiaClientBuilder = OxiaClientBuilder
@@ -91,7 +87,6 @@ public class OxiaMetadataStore extends AbstractMetadataStore {
.clientIdentifier(identity)
.namespace(namespace)
.sessionTimeout(Duration.ofMillis(metadataStoreConfig.getSessionTimeoutMillis()))
- .batchLinger(Duration.ofMillis(linger))
.maxRequestsPerBatch(metadataStoreConfig.getBatchingMaxOperations());
if (StringUtils.isNotBlank(metadataStoreConfig.getConfigFilePath())) {
oxiaClientBuilder.loadConfig(metadataStoreConfig.getConfigFilePath());
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStoreProvider.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStoreProvider.java
index 2b7dbfce7280..7c521599a8d8 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStoreProvider.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStoreProvider.java
@@ -20,8 +20,6 @@ package org.apache.pulsar.metadata.impl.oxia;
import io.oxia.client.api.AsyncOxiaClient;
import io.oxia.client.api.OxiaClientBuilder;
-import java.time.Duration;
-import java.time.temporal.ChronoUnit;
import lombok.NonNull;
import org.apache.commons.lang3.tuple.Pair;
import org.apache.pulsar.metadata.api.MetadataStore;
@@ -82,7 +80,6 @@ public class OxiaMetadataStoreProvider implements MetadataStoreProvider {
try {
return OxiaClientBuilder.create(pair.getLeft())
.namespace(pair.getRight())
- .batchLinger(Duration.of(100, ChronoUnit.MILLIS))
.asyncClient().get();
} catch (Exception e) {
throw new MetadataStoreException(e);