Skip to content

Commit 760af72

Browse files
committed
collect only relevant meta for deletion vector merge
1 parent fa2e8f1 commit 760af72

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -696,7 +696,7 @@ class GpuDeltaParquetFileFormatBase2(
696696
): HostMemoryBuffersWithMetaData = {
697697
val metaToUse = combinedMeta.firstNonEmpty
698698
val toCombine = combinedMeta.toCombine
699-
.map(_.asInstanceOf[DeltaParquetHostMemoryBuffersWithMetaData])
699+
.collect { case hmb: DeltaParquetHostMemoryBuffersWithMetaData => hmb }
700700
val combinedDVMeta = DeletionVectorMetadata.combine(toCombine.flatMap(_.dvMetadata))
701701

702702
DeltaParquetHostMemoryBuffersWithMetaData(

0 commit comments

Comments
 (0)