This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 298b5b7c42b [improve][ml] Upgrade Oxia client to 0.7.0 (#24824)
298b5b7c42b is described below
commit 298b5b7c42b7498c2ef61b3c61565150ac487943
Author: Matteo Merli <[email protected]>
AuthorDate: Tue Oct 7 16:14:12 2025 -0700
[improve][ml] Upgrade Oxia client to 0.7.0 (#24824)
---
distribution/server/src/assemble/LICENSE.bin.txt | 4 ++--
pom.xml | 2 +-
.../org/apache/pulsar/metadata/impl/oxia/OxiaMetadataStore.java | 6 +++---
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/distribution/server/src/assemble/LICENSE.bin.txt
b/distribution/server/src/assemble/LICENSE.bin.txt
index 11555b1896f..aabf3fd9d79 100644
--- a/distribution/server/src/assemble/LICENSE.bin.txt
+++ b/distribution/server/src/assemble/LICENSE.bin.txt
@@ -484,8 +484,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.6.2.jar
- - io.github.oxia-db-oxia-client-0.6.2.jar
+ - io.github.oxia-db-oxia-client-api-0.7.0.jar
+ - io.github.oxia-db-oxia-client-0.7.0.jar
* OpenHFT
- net.openhft-zero-allocation-hashing-0.16.jar
* Java JSON WebTokens
diff --git a/pom.xml b/pom.xml
index 2082f4c1fa6..55f1fbf4e22 100644
--- a/pom.xml
+++ b/pom.xml
@@ -293,7 +293,7 @@ flexible messaging model and an intuitive client
API.</description>
<apache-http-client.version>4.5.13</apache-http-client.version>
<apache-httpcomponents.version>4.4.15</apache-httpcomponents.version>
<jetcd.version>0.7.7</jetcd.version>
- <oxia.version>0.6.2</oxia.version>
+ <oxia.version>0.7.0</oxia.version>
<snakeyaml.version>2.0</snakeyaml.version>
<ant.version>1.10.12</ant.version>
<seancfoley.ipaddress.version>5.5.0</seancfoley.ipaddress.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 7f0dc6fba10..058e447d49a 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
@@ -20,14 +20,14 @@ package org.apache.pulsar.metadata.impl.oxia;
import io.opentelemetry.api.OpenTelemetry;
import io.oxia.client.api.AsyncOxiaClient;
-import io.oxia.client.api.DeleteOption;
import io.oxia.client.api.Notification;
import io.oxia.client.api.OxiaClientBuilder;
-import io.oxia.client.api.PutOption;
import io.oxia.client.api.PutResult;
import io.oxia.client.api.Version;
import io.oxia.client.api.exceptions.KeyAlreadyExistsException;
import io.oxia.client.api.exceptions.UnexpectedVersionIdException;
+import io.oxia.client.api.options.DeleteOption;
+import io.oxia.client.api.options.PutOption;
import java.time.Duration;
import java.util.Collections;
import java.util.EnumSet;
@@ -133,7 +133,7 @@ public class OxiaMetadataStore extends
AbstractMetadataStore {
return Optional.of(result)
.map(
oxiaResult ->
- new GetResult(oxiaResult.getValue(),
convertStat(path, oxiaResult.getVersion())));
+ new GetResult(oxiaResult.value(),
convertStat(path, oxiaResult.version())));
}
Stat convertStat(String path, Version version) {