Skip to content

Commit 7e2d1a9

Browse files
committed
bug fix: indexr-spark null pointer exception with illegal segment file
1 parent b3af42b commit 7e2d1a9

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

Diff for: indexr-spark/src/main/java/org/apache/spark/sql/execution/datasources/indexr/IndexRRecordReader.java

+8-6
Original file line numberDiff line numberDiff line change
@@ -82,12 +82,14 @@ public void initialize(InputSplit inputSplit, TaskAttemptContext taskAttemptCont
8282

8383
ByteBufferReader.Opener opener = ByteBufferReader.Opener.create(fileSystem, filePath);
8484
IntegratedSegment.Fd fd = IntegratedSegment.Fd.create(filePath.toString(), opener);
85-
if (fd != null) {
86-
segment = fd.open();
87-
if (segment == null) {
88-
logger.warn("illegal segment: " + filePath);
89-
return;
90-
}
85+
if (fd == null) {
86+
logger.warn("illegal segment: " + filePath);
87+
return;
88+
}
89+
segment = fd.open();
90+
if (segment == null) {
91+
logger.warn("illegal segment: " + filePath);
92+
return;
9193
}
9294
this.totalRowCount = segment.rowCount();
9395
this.packCount = segment.packCount();

0 commit comments

Comments
 (0)