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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
