(drill) branch master updated: DRILL-8479: Merge Join Memory Leak Depleting Incoming Batches Throw Exception (#2878)

[cgivre]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 26f4d30dbe DRILL-8479: Merge Join Memory Leak Depleting Incoming 
Batches Throw Exception (#2878)
26f4d30dbe is described below

commit 26f4d30dbefcc09a7dfe05576d3f9c7b45d822a0
Author: shfshihuafeng <shfshihuaf...@163.com>
AuthorDate: Wed Mar 6 12:00:30 2024 +0800

    DRILL-8479: Merge Join Memory Leak Depleting Incoming Batches Throw 
Exception (#2878)
---
 .../org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
 
b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
index cd1ba748c9..ca92ff702b 100644
--- 
a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
+++ 
b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/join/MergeJoinBatch.java
@@ -297,7 +297,14 @@ public class MergeJoinBatch extends 
AbstractBinaryRecordBatch<MergeJoinPOP> {
       batchMemoryManager.getAvgOutputRowWidth(), 
batchMemoryManager.getTotalOutputRecords());
 
     super.close();
-    leftIterator.close();
+    try {
+      leftIterator.close();
+    } catch (Exception e) {
+      rightIterator.close();
+      throw UserException.executionError(e)
+          .message("Failed to close Iterator.")
+          .build(logger);
+    }
     rightIterator.close();
   }