(paimon) branch master updated: [spark] fix bug that use the wrong version of commit message serializer (#3921)

[zouxxyy]

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

zouxxyy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 55e923c17 [spark] fix bug that use the wrong version of commit message 
serializer (#3921)
55e923c17 is described below

commit 55e923c17396fac5e0c66ff7a3b6ff499df8df52
Author: Yann Byron <biyan900...@gmail.com>
AuthorDate: Thu Aug 8 22:44:43 2024 +0800

    [spark] fix bug that use the wrong version of commit message serializer 
(#3921)
---
 .../main/java/org/apache/paimon/spark/procedure/CompactProcedure.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
index eaf7e3a00..801574818 100644
--- 
a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
+++ 
b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
@@ -384,7 +384,7 @@ public class CompactProcedure extends BaseProcedure {
             for (byte[] serializedMessage : serializedMessages) {
                 messages.add(
                         messageSerializerser.deserialize(
-                                serializer.getVersion(), serializedMessage));
+                                messageSerializerser.getVersion(), 
serializedMessage));
             }
             commit.commit(messages);
         } catch (Exception e) {