(hudi) branch master updated: [MINOR] Fix flaky test (#13626)

[sivabalan]

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

sivabalan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 3e3404a6c8bc [MINOR] Fix flaky test (#13626)
3e3404a6c8bc is described below

commit 3e3404a6c8bcdb93058b1fd56933d9f2b39d6781
Author: Davis-Zhang-Onehouse 
<169106455+davis-zhang-oneho...@users.noreply.github.com>
AuthorDate: Sat Jul 26 07:45:15 2025 -0700

    [MINOR] Fix flaky test (#13626)
---
 .../org/apache/hudi/common/data/TestHoodieListDataPairData.java    | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListDataPairData.java
 
b/hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListDataPairData.java
index 3cebc5995367..07d463362797 100644
--- 
a/hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListDataPairData.java
+++ 
b/hudi-common/src/test/java/org/apache/hudi/common/data/TestHoodieListDataPairData.java
@@ -36,6 +36,7 @@ import java.util.Comparator;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import java.util.stream.StreamSupport;
@@ -153,7 +154,7 @@ public class TestHoodieListDataPairData {
 
   @Test
   void testReduceByKeyWithCloseableInput() {
-    List<CloseValidationIterator<Pair<Integer, Integer>>> createdIterators = 
new ArrayList<>();
+    ConcurrentLinkedQueue<CloseValidationIterator<Pair<Integer, Integer>>> 
createdIterators = new ConcurrentLinkedQueue<>();
     HoodiePairData<Integer, Integer> data = 
HoodieListData.lazy(Arrays.asList(1, 1, 1))
         .flatMapToPair(key -> {
           CloseValidationIterator<Pair<Integer, Integer>> iter = new 
CloseValidationIterator<>(Collections.singletonList(Pair.of(key, 
1)).iterator());
@@ -167,7 +168,7 @@ public class TestHoodieListDataPairData {
 
   @Test
   void testLeftOuterJoinWithCloseableInput() {
-    List<CloseValidationIterator<Pair<Integer, Integer>>> createdIterators = 
new ArrayList<>();
+    ConcurrentLinkedQueue<CloseValidationIterator<Pair<Integer, Integer>>> 
createdIterators = new ConcurrentLinkedQueue<>();
     HoodiePairData<Integer, Integer> dataToJoin = 
HoodieListData.lazy(Arrays.asList(1, 2, 3))
         .flatMapToPair(key -> {
           CloseValidationIterator<Pair<Integer, Integer>> iter = new 
CloseValidationIterator<>(Collections.singletonList(Pair.of(key, 
1)).iterator());
@@ -182,7 +183,7 @@ public class TestHoodieListDataPairData {
 
   @Test
   void testJoinWithCloseableInput() {
-    List<CloseValidationIterator<Pair<Integer, Integer>>> createdIterators = 
new ArrayList<>();
+    ConcurrentLinkedQueue<CloseValidationIterator<Pair<Integer, Integer>>> 
createdIterators = new ConcurrentLinkedQueue<>();
     HoodiePairData<Integer, Integer> dataToJoin = 
HoodieListData.lazy(Arrays.asList(1, 2, 3))
         .flatMapToPair(key -> {
           CloseValidationIterator<Pair<Integer, Integer>> iter = new 
CloseValidationIterator<>(Collections.singletonList(Pair.of(key, 
1)).iterator());