(paimon) branch master updated: [core] Fix FileStoreCommitTest.testIndexFiles flaky ut (#3358)

[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/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 7579c8365 [core] Fix FileStoreCommitTest.testIndexFiles flaky ut 
(#3358)
7579c8365 is described below

commit 7579c8365c06f5a59e15a3c8131e21ea1ab408e8
Author: Yann Byron <biyan900...@gmail.com>
AuthorDate: Tue May 21 15:52:49 2024 +0800

    [core] Fix FileStoreCommitTest.testIndexFiles flaky ut (#3358)
---
 .../apache/paimon/operation/FileStoreCommitTest.java | 20 ++++++++++++--------
 1 file changed, 12 insertions(+), 8 deletions(-)

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 26cb564ca..d603eda41 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
@@ -719,12 +719,14 @@ public class FileStoreCommitTest {
                 indexFileHandler.scan(snapshot.id(), HASH_INDEX, part1);
         assertThat(part1Index.size()).isEqualTo(2);
 
-        assertThat(part1Index.get(0).bucket()).isEqualTo(0);
-        
assertThat(indexFileHandler.readHashIndexList(part1Index.get(0).indexFile()))
+        IndexManifestEntry indexManifestEntry =
+                part1Index.stream().filter(entry -> entry.bucket() == 
0).findAny().get();
+        
assertThat(indexFileHandler.readHashIndexList(indexManifestEntry.indexFile()))
                 .containsExactlyInAnyOrder(1, 2, 5);
 
-        assertThat(part1Index.get(1).bucket()).isEqualTo(1);
-        
assertThat(indexFileHandler.readHashIndexList(part1Index.get(1).indexFile()))
+        indexManifestEntry =
+                part1Index.stream().filter(entry -> entry.bucket() == 
1).findAny().get();
+        
assertThat(indexFileHandler.readHashIndexList(indexManifestEntry.indexFile()))
                 .containsExactlyInAnyOrder(6, 8);
 
         // assert part2
@@ -744,12 +746,14 @@ public class FileStoreCommitTest {
         part1Index = indexFileHandler.scan(snapshot.id(), HASH_INDEX, part1);
         assertThat(part1Index.size()).isEqualTo(2);
 
-        assertThat(part1Index.get(0).bucket()).isEqualTo(0);
-        
assertThat(indexFileHandler.readHashIndexList(part1Index.get(0).indexFile()))
+        indexManifestEntry =
+                part1Index.stream().filter(entry -> entry.bucket() == 
0).findAny().get();
+        
assertThat(indexFileHandler.readHashIndexList(indexManifestEntry.indexFile()))
                 .containsExactlyInAnyOrder(1, 4);
 
-        assertThat(part1Index.get(1).bucket()).isEqualTo(1);
-        
assertThat(indexFileHandler.readHashIndexList(part1Index.get(1).indexFile()))
+        indexManifestEntry =
+                part1Index.stream().filter(entry -> entry.bucket() == 
1).findAny().get();
+        
assertThat(indexFileHandler.readHashIndexList(indexManifestEntry.indexFile()))
                 .containsExactlyInAnyOrder(6, 8);
 
         // assert scan one bucket