(fluss) branch main updated: [hotfix] Fix serialize modifiedTime field in TableRegistrationJsonSerde (#2810)

[liebing]

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

liebing 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 d72ba3ab2 [hotfix] Fix serialize modifiedTime field in 
TableRegistrationJsonSerde (#2810)
d72ba3ab2 is described below

commit d72ba3ab24a444e52c7846bf35eb7d00375364b2
Author: Yang Guo <100583615+gyan...@users.noreply.github.com>
AuthorDate: Mon Mar 16 09:54:06 2026 +0800

    [hotfix] Fix serialize modifiedTime field in TableRegistrationJsonSerde 
(#2810)
---
 .../org/apache/fluss/server/zk/data/TableRegistrationJsonSerde.java | 2 +-
 .../apache/fluss/server/zk/data/TableRegistrationJsonSerdeTest.java | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/fluss-server/src/main/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerde.java
 
b/fluss-server/src/main/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerde.java
index 122d081e4..be7fcddc2 100644
--- 
a/fluss-server/src/main/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerde.java
+++ 
b/fluss-server/src/main/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerde.java
@@ -104,7 +104,7 @@ public class TableRegistrationJsonSerde
         generator.writeNumberField(CREATED_TIME, tableReg.createdTime);
 
         // serialize modifiedTime
-        generator.writeNumberField(MODIFIED_TIME, tableReg.createdTime);
+        generator.writeNumberField(MODIFIED_TIME, tableReg.modifiedTime);
 
         generator.writeEndObject();
     }
diff --git 
a/fluss-server/src/test/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerdeTest.java
 
b/fluss-server/src/test/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerdeTest.java
index 348b20cfc..40566b639 100644
--- 
a/fluss-server/src/test/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerdeTest.java
+++ 
b/fluss-server/src/test/java/org/apache/fluss/server/zk/data/TableRegistrationJsonSerdeTest.java
@@ -49,7 +49,7 @@ class TableRegistrationJsonSerdeTest extends 
JsonSerdeTestBase<TableRegistration
                                         Maps.newHashMap(),
                                         Collections.singletonMap("custom-3", 
"\"300\""),
                                         1735538268L,
-                                        1735538268L))
+                                        1735538270L))
                 .isInstanceOf(IllegalArgumentException.class)
                 .hasMessage("Bucket count is required for table 
registration.");
 
@@ -78,7 +78,7 @@ class TableRegistrationJsonSerdeTest extends 
JsonSerdeTestBase<TableRegistration
                         Maps.newHashMap(),
                         Collections.singletonMap("custom-3", "\"300\""),
                         1735538268L,
-                        1735538268L);
+                        1735538270L);
 
         tableRegistrations[1] =
                 new TableRegistration(
@@ -98,7 +98,7 @@ class TableRegistrationJsonSerdeTest extends 
JsonSerdeTestBase<TableRegistration
     protected String[] expectedJsons() {
         return new String[] {
             
"{\"version\":1,\"table_id\":1234,\"comment\":\"first-table\",\"partition_key\":[\"a\",\"b\"],"
-                    + 
"\"bucket_key\":[\"b\",\"c\"],\"bucket_count\":16,\"properties\":{},\"custom_properties\":{\"custom-3\":\"\\\"300\\\"\"},\"created_time\":1735538268,\"modified_time\":1735538268}",
+                    + 
"\"bucket_key\":[\"b\",\"c\"],\"bucket_count\":16,\"properties\":{},\"custom_properties\":{\"custom-3\":\"\\\"300\\\"\"},\"created_time\":1735538268,\"modified_time\":1735538270}",
             
"{\"version\":1,\"table_id\":1234,\"comment\":\"second-table\",\"bucket_count\":32,\"properties\":{\"option-3\":\"300\"},\"custom_properties\":{},\"created_time\":-1,\"modified_time\":-1}",
         };
     }