(fluss) branch main updated: [hotfix][server] KvSnapshotLeaseMetadataJsonSerde serialize kv snapshot path use toString() instead of getPath() (#2633)

[yunhong]

This is an automated email from the ASF dual-hosted git repository.

yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new e5912782c [hotfix][server] KvSnapshotLeaseMetadataJsonSerde serialize 
kv snapshot path use toString() instead of getPath() (#2633)
e5912782c is described below

commit e5912782cf22c221d763b119040f121b4421ca61
Author: yunhong <337361...@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\":[]}"
         };
     }