[incubator-paimon] branch master updated: [core] fix the issue that partitionExpire will fail when logOffsets is not empty. (#1977)

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 2c79d5564 [core] fix the issue that partitionExpire will fail when 
logOffsets is not empty. (#1977)
2c79d5564 is described below

commit 2c79d556473fc43e8be6274dc88158895fe66a90
Author: liming.1018 <69444450+limin...@users.noreply.github.com>
AuthorDate: Sat Sep 9 16:10:40 2023 +0800

    [core] fix the issue that partitionExpire will fail when logOffsets is not 
empty. (#1977)
---
 .../src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java | 2 +-
 .../src/test/java/org/apache/paimon/operation/FileStoreCommitTest.java | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
 
b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
index 249b0105f..59dee5358 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java
@@ -393,7 +393,7 @@ public class FileStoreCommitImpl implements FileStoreCommit 
{
                 Collections.emptyList(),
                 commitIdentifier,
                 null,
-                Collections.emptyMap());
+                new HashMap<>());
     }
 
     @Override
diff --git 
a/paimon-core/src/test/java/org/apache/paimon/operation/FileStoreCommitTest.java
 
b/paimon-core/src/test/java/org/apache/paimon/operation/FileStoreCommitTest.java
index 87ffd9675..10cde724a 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/operation/FileStoreCommitTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/operation/FileStoreCommitTest.java
@@ -609,7 +609,8 @@ public class FileStoreCommitTest {
         store.commitData(
                 
data.values().stream().flatMap(Collection::stream).collect(Collectors.toList()),
                 gen::getPartition,
-                kv -> 0);
+                kv -> 0,
+                Collections.singletonMap(0, 1L));
 
         // generate partitions to be dropped
         ThreadLocalRandom random = ThreadLocalRandom.current();