Skip to content

Commit 98744b2

Browse files
committed
fix the condition
1 parent 7eae846 commit 98744b2

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

delta-lake/common/src/main/delta-33x-40x/scala/com/nvidia/spark/rapids/delta/common/GpuDeltaParquetFileFormatBase.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -237,11 +237,11 @@ class GpuDeltaParquetFileFormatBase(
237237
fileScan.allMetrics,
238238
useMetadataRowIndex = false,
239239
tablePath,
240-
// queryUsesInputFile is used to enable combining small files in the multi-threaded reader.
240+
// queryUsesInputFile is used to disable combining small files in the multi-threaded reader.
241241
// When it is true, combining small files is disabled. Since we don't currently support
242242
// combining small files with deletion vectors, we need to disable it when deletion vectors
243243
// exist (which is when tablePath is defined).
244-
queryUsesInputFile = tablePath.isEmpty && fileScan.queryUsesInputFile)
244+
queryUsesInputFile = hasTablePath || fileScan.queryUsesInputFile)
245245
}
246246

247247
/**

0 commit comments

Comments
 (0)