You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by sn...@apache.org on 2023/06/21 17:30:41 UTC
[pinot] branch master updated: Null check before closing reader (#10954)
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 <12...@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-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org