File tree Expand file tree Collapse file tree 1 file changed +14
-11
lines changed
paimon-core/src/main/java/org/apache/paimon/operation Expand file tree Collapse file tree 1 file changed +14
-11
lines changed Original file line number Diff line number Diff line change @@ -199,17 +199,20 @@ private FileRecordReader<InternalRow> createFileReader(
199
199
throws IOException {
200
200
FileIndexResult fileIndexResult = null ;
201
201
if (fileIndexReadEnabled ) {
202
- Predicate dataPredicate =
203
- PredicateBuilder .and (
204
- formatReaderMapping .getDataFilters ().toArray (new Predicate [0 ]));
205
- fileIndexResult =
206
- FileIndexEvaluator .evaluate (
207
- fileIO ,
208
- formatReaderMapping .getDataSchema (),
209
- dataPredicate ,
210
- dataFilePathFactory ,
211
- file );
212
- if (!fileIndexResult .remain ()) {
202
+ List <Predicate > dataFilters = formatReaderMapping .getDataFilters ();
203
+ if (dataFilters != null && !dataFilters .isEmpty ()) {
204
+ Predicate dataPredicate =
205
+ PredicateBuilder .and (
206
+ formatReaderMapping .getDataFilters ().toArray (new Predicate [0 ]));
207
+ fileIndexResult =
208
+ FileIndexEvaluator .evaluate (
209
+ fileIO ,
210
+ formatReaderMapping .getDataSchema (),
211
+ dataPredicate ,
212
+ dataFilePathFactory ,
213
+ file );
214
+ }
215
+ if (fileIndexResult != null && !fileIndexResult .remain ()) {
213
216
return new EmptyFileRecordReader <>();
214
217
}
215
218
}
You can’t perform that action at this time.
0 commit comments