Skip to content

Commit

Permalink
[spark] fix bug that use the wrong version of commit message serializ…
Browse files Browse the repository at this point in the history
…er (#3921)
  • Loading branch information
YannByron authored Aug 8, 2024
1 parent 3b9dd9b commit 55e923c
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down

0 comments on commit 55e923c

Please sign in to comment.