You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@fluss.apache.org by ja...@apache.org on 2026/02/12 09:52:08 UTC
(fluss) 03/19: [hotfix][server] KvSnapshotLeaseMetadataJsonSerde serialize kv snapshot path use toString() instead of getPath() (#2633)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-0.9
in repository https://gitbox.apache.org/repos/asf/fluss.git
commit e81c8c3167ef73d69c813dd11d59173afb6ef51a
Author: yunhong <33...@qq.com>
AuthorDate: Wed Feb 11 10:26:02 2026 +0800
[hotfix][server] KvSnapshotLeaseMetadataJsonSerde serialize kv snapshot path use toString() instead of getPath() (#2633)
---
.../server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerde.java | 2 +-
.../zk/data/lease/KvSnapshotLeaseMetadataJsonSerdeTest.java | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/fluss-server/src/main/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerde.java b/fluss-server/src/main/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerde.java
index 30c9367da..1e729b57d 100644
--- a/fluss-server/src/main/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerde.java
+++ b/fluss-server/src/main/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerde.java
@@ -56,7 +56,7 @@ public class KvSnapshotLeaseMetadataJsonSerde
kvSnapshotLeaseMetadata.getTableIdToRemoteMetadataFilePath().entrySet()) {
generator.writeStartObject();
generator.writeNumberField(TABLE_ID, entry.getKey());
- generator.writeStringField(KV_SNAPSHOT_PATH, entry.getValue().getPath());
+ generator.writeStringField(KV_SNAPSHOT_PATH, entry.getValue().toString());
generator.writeEndObject();
}
// end tables
diff --git a/fluss-server/src/test/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerdeTest.java b/fluss-server/src/test/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerdeTest.java
index b4ed0654d..caa76c6ae 100644
--- a/fluss-server/src/test/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerdeTest.java
+++ b/fluss-server/src/test/java/org/apache/fluss/server/zk/data/lease/KvSnapshotLeaseMetadataJsonSerdeTest.java
@@ -36,8 +36,8 @@ public class KvSnapshotLeaseMetadataJsonSerdeTest
protected KvSnapshotLeaseMetadata[] createObjects() {
KvSnapshotLeaseMetadata[] kvSnapshotLeaseMetadata = new KvSnapshotLeaseMetadata[2];
Map<Long, FsPath> tableIdToRemoteMetadataFilePath = new HashMap<>();
- tableIdToRemoteMetadataFilePath.put(1L, new FsPath("/path/to/metadata1"));
- tableIdToRemoteMetadataFilePath.put(2L, new FsPath("/path/to/metadata2"));
+ tableIdToRemoteMetadataFilePath.put(1L, new FsPath("oss://path/to/metadata1"));
+ tableIdToRemoteMetadataFilePath.put(2L, new FsPath("s3://path/to/metadata2"));
kvSnapshotLeaseMetadata[0] =
new KvSnapshotLeaseMetadata(1735538268L, tableIdToRemoteMetadataFilePath);
kvSnapshotLeaseMetadata[1] =
@@ -49,8 +49,8 @@ public class KvSnapshotLeaseMetadataJsonSerdeTest
protected String[] expectedJsons() {
return new String[] {
"{\"version\":1,\"expiration_time\":1735538268,\"tables\":"
- + "[{\"table_id\":1,\"lease_metadata_path\":\"/path/to/metadata1\"},"
- + "{\"table_id\":2,\"lease_metadata_path\":\"/path/to/metadata2\"}]}",
+ + "[{\"table_id\":1,\"lease_metadata_path\":\"oss://path/to/metadata1\"},"
+ + "{\"table_id\":2,\"lease_metadata_path\":\"s3://path/to/metadata2\"}]}",
"{\"version\":1,\"expiration_time\":1735538268,\"tables\":[]}"
};
}