Skip to content

Commit 6972f82

Browse files
committed
fixup! Report physical size written by the MERGE statement
1 parent 5131199 commit 6972f82

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeMergeSink.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -502,6 +502,7 @@ private List<Slice> rewriteFile(String sourcePath, FileDeletion deletion)
502502
DATA);
503503

504504
Optional<DataFileInfo> newFileInfo = rewriteParquetFile(sourceLocation, deletion, writer);
505+
writtenBytes += writer.getWrittenBytes();
505506

506507
DeltaLakeMergeResult result = new DeltaLakeMergeResult(deletion.partitionValues(), Optional.of(sourceReferencePath), Optional.empty(), newFileInfo);
507508
return ImmutableList.of(utf8Slice(mergeResultJsonCodec.toJson(result)));

0 commit comments

Comments
 (0)