(fluss) branch main updated: [paimon] Use right serializer version of PaimonWriteResult and PaimonCommittable (#1368)

[yuxia]

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

yuxia 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 0cb2d6126 [paimon] Use right serializer version of PaimonWriteResult 
and PaimonCommittable (#1368)
0cb2d6126 is described below

commit 0cb2d6126550fe06a43d083c9f7530f5e6542d5b
Author: xx789 <maxcw...@tencent.com>
AuthorDate: Mon Jul 21 10:35:18 2025 +0800

    [paimon] Use right serializer version of PaimonWriteResult and 
PaimonCommittable (#1368)
---
 .../alibaba/fluss/lake/paimon/tiering/PaimonCommittableSerializer.java | 3 ++-
 .../alibaba/fluss/lake/paimon/tiering/PaimonWriteResultSerializer.java | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonCommittableSerializer.java
 
b/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonCommittableSerializer.java
index 9e98124a2..218eb1197 100644
--- 
a/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonCommittableSerializer.java
+++ 
b/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonCommittableSerializer.java
@@ -54,7 +54,8 @@ public class PaimonCommittableSerializer implements 
SimpleVersionedSerializer<Pa
                             + ".");
         }
         ManifestCommittable manifestCommittable =
-                manifestCommittableSerializer.deserialize(version, serialized);
+                manifestCommittableSerializer.deserialize(
+                        manifestCommittableSerializer.getVersion(), 
serialized);
         return new PaimonCommittable(manifestCommittable);
     }
 }
diff --git 
a/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonWriteResultSerializer.java
 
b/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonWriteResultSerializer.java
index 468eeeaf0..bad9ebb65 100644
--- 
a/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonWriteResultSerializer.java
+++ 
b/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonWriteResultSerializer.java
@@ -52,7 +52,7 @@ public class PaimonWriteResultSerializer implements 
SimpleVersionedSerializer<Pa
                             + version
                             + ".");
         }
-        CommitMessage commitMessage = messageSer.deserialize(version, 
serialized);
+        CommitMessage commitMessage = 
messageSer.deserialize(messageSer.getVersion(), serialized);
         return new PaimonWriteResult(commitMessage);
     }
 }