From 55e923c17396fac5e0c66ff7a3b6ff499df8df52 Mon Sep 17 00:00:00 2001
From: Yann Byron <biyan900116@gmail.com>
Date: Thu, 8 Aug 2024 22:44:43 +0800
Subject: [PATCH] [spark] fix bug that use the wrong version of commit message
 serializer (#3921)

---
 .../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 eaf7e3a00e1f..801574818e80 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 @@ private void compactUnAwareBucketTable(
             for (byte[] serializedMessage : serializedMessages) {
                 messages.add(
                         messageSerializerser.deserialize(
-                                serializer.getVersion(), serializedMessage));
+                                messageSerializerser.getVersion(), serializedMessage));
             }
             commit.commit(messages);
         } catch (Exception e) {