[hudi] branch master updated: [MINOR] Close record readers after use during tests (#9457)

[danny0405]

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

danny0405 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 5a7b5f28d99 [MINOR] Close record readers after use during tests (#9457)
5a7b5f28d99 is described below

commit 5a7b5f28d99d16a7ca363a490a70702a87d85a89
Author: voonhous <voonho...@gmail.com>
AuthorDate: Sun Aug 20 09:45:51 2023 +0800

    [MINOR] Close record readers after use during tests (#9457)
---
 .../test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java
 
b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java
index 6f787db6069..7185115a4d5 100644
--- 
a/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java
+++ 
b/hudi-client/hudi-client-common/src/test/java/org/apache/hudi/testutils/HoodieMergeOnReadTestUtils.java
@@ -166,6 +166,7 @@ public class HoodieMergeOnReadTestUtils {
               .forEach(fieldsPair -> newRecord.set(fieldsPair.getKey(), 
values[fieldsPair.getValue().pos()]));
           records.add(newRecord.build());
         }
+        recordReader.close();
       }
     } catch (IOException ie) {
       LOG.error("Read records error", ie);