Skip to content

Commit d76fb9f

Browse files
committed
Update comment to link to iceberg java issue.
1 parent dd8e338 commit d76fb9f

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

spark/src/main/scala/org/apache/comet/serde/operator/CometIcebergNativeScan.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -268,11 +268,11 @@ object CometIcebergNativeScan extends CometOperatorSerde[CometBatchScanExec] wit
268268
}
269269
deleteBuilder.setPartitionSpecId(specId)
270270

271-
// Workaround for Iceberg Java bug:
271+
// Workaround for https://github.com/apache/iceberg/issues/12554
272272
// RewriteTablePath rewrites path references inside position delete files,
273-
// making the copied file larger, but does not update file_size_in_bytes in
274-
// the manifest. The manifest value cannot be trusted; always use FileIO to
275-
// get the actual size.
273+
// making the copied file possibly differ in size, but does not update
274+
// file_size_in_bytes in the manifest. The manifest value cannot be trusted;
275+
// always use FileIO to get the actual size.
276276
val inputFile = fileIO.get.getClass
277277
.getMethod("newInputFile", classOf[String])
278278
.invoke(fileIO.get, deletePath)

0 commit comments

Comments
 (0)