Use updated metric API for iceberg

infvg · infvg · commit 208bdfcd6eca · 2026-02-19T13:39:05.000+03:00
diff --git a/velox/connectors/hive/iceberg/IcebergDataSink.cpp b/velox/connectors/hive/iceberg/IcebergDataSink.cpp
@@ -506,6 +506,7 @@ void IcebergDataSink::closeInternal() {
         WRITER_NON_RECLAIMABLE_SECTION_GUARD(i);
         writers_[i]->close();
         dataFileStats_.push_back(writers_[i]->dataFileStats());
+        finalizeWriterFile(i);
       }
     }
   } else {

Original file line number	Diff line number	Diff line change
`@@ -506,6 +506,7 @@ void IcebergDataSink::closeInternal() {`
`506`	`506`	`WRITER_NON_RECLAIMABLE_SECTION_GUARD(i);`
`507`	`507`	`writers_[i]->close();`
`508`	`508`	`dataFileStats_.push_back(writers_[i]->dataFileStats());`
	`509`	`+ finalizeWriterFile(i);`
`509`	`510`	`}`
`510`	`511`	`}`
`511`	`512`	`} else {`