You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by pw...@apache.org on 2023/09/01 11:27:51 UTC
[hudi] 04/30: [MINOR] Close record readers after use during tests (#9457)
This is an automated email from the ASF dual-hosted git repository.
pwason pushed a commit to branch release-0.14.0
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 6a6bfd7c1e0a08fdb14324d477cb6f44d834f40f
Author: voonhous <vo...@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);