[pinot] branch master updated: Null check before closing reader (#10954)

[snlee]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 70020005b1 Null check before closing reader (#10954)
70020005b1 is described below

commit 70020005b1a878acc4efa5f813162dd8c3db80c0
Author: swaminathanmanish <126024920+swaminathanman...@users.noreply.github.com>
AuthorDate: Wed Jun 21 10:30:36 2023 -0700

    Null check before closing reader (#10954)
---
 .../apache/pinot/core/segment/processing/mapper/SegmentMapper.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/mapper/SegmentMapper.java
 
b/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/mapper/SegmentMapper.java
index dae6fd52ee..00b61e04e8 100644
--- 
a/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/mapper/SegmentMapper.java
+++ 
b/pinot-core/src/main/java/org/apache/pinot/core/segment/processing/mapper/SegmentMapper.java
@@ -138,7 +138,9 @@ public class SegmentMapper {
                   recordReaderFileConfig._fieldsToRead, 
recordReaderFileConfig._recordReaderConfig);
           mapAndTransformRow(recordReader, reuse, observer, count, totalCount);
         } finally {
-          recordReader.close();
+          if (recordReader != null) {
+            recordReader.close();
+          }
         }
       } else {
         mapAndTransformRow(recordReader, reuse, observer, count, totalCount);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org