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 <[email protected]> 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\":[]}" }; }
