[incubator-paimon] branch release-0.4 updated: [test] Fix unstable test: PartitionExpireTest.testFilterCommittedAfterExpiring

[lzljs3620320]

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

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


The following commit(s) were added to refs/heads/release-0.4 by this push:
     new 3d9d7b0dd [test] Fix unstable test: 
PartitionExpireTest.testFilterCommittedAfterExpiring
3d9d7b0dd is described below

commit 3d9d7b0dd9a0fb9f0610da76b97f0a1cffb60fff
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Thu May 4 12:22:16 2023 +0800

    [test] Fix unstable test: 
PartitionExpireTest.testFilterCommittedAfterExpiring
---
 .../java/org/apache/paimon/operation/PartitionExpireTest.java    | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java
 
b/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java
index 7dae4405c..1b143150e 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/operation/PartitionExpireTest.java
@@ -44,6 +44,7 @@ import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
+import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -148,16 +149,16 @@ public class PartitionExpireTest {
         ThreadLocalRandom random = ThreadLocalRandom.current();
 
         // prepare commits
-        int now =
-                Integer.parseInt(
-                        
LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMdd")));
+        LocalDate now = LocalDate.now();
         int preparedCommits = random.nextInt(20, 30);
 
         List<List<CommitMessage>> commitMessages = new ArrayList<>();
         Set<Long> notCommitted = new HashSet<>();
         for (int i = 0; i < preparedCommits; i++) {
             // ensure the partition will be expired
-            String f0 = String.valueOf(now - random.nextInt(10));
+            String f0 =
+                    now.minus(random.nextInt(10), ChronoUnit.DAYS)
+                            .format(DateTimeFormatter.ofPattern("yyyyMMdd"));
             String f1 = String.valueOf(random.nextInt(25));
             StreamTableWrite write = table.newWrite(commitUser);
             write.write(GenericRow.of(BinaryString.fromString(f0), 
BinaryString.fromString(f1)));