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 12:05:49 UTC
(pulsar) 09/16: [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.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 52b295b7c9d9ce714dfc11d40844373c2d3c2d42
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 -----
3 files changed, 3 insertions(+), 8 deletions(-)
diff --git a/distribution/server/src/assemble/LICENSE.bin.txt b/distribution/server/src/assemble/LICENSE.bin.txt
index 1268d412b563..b9db4f110d8c 100644
--- a/distribution/server/src/assemble/LICENSE.bin.txt
+++ b/distribution/server/src/assemble/LICENSE.bin.txt
@@ -497,8 +497,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 92fdfdd09099..9fd126cd6a00 100644
--- a/pom.xml
+++ b/pom.xml
@@ -294,7 +294,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 c1e65d4eac1e..914253e8630f 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
@@ -77,10 +77,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
@@ -88,7 +84,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());