This is an automated email from the ASF dual-hosted git repository.

Amar3tto pushed a commit to branch icerbergio-benchmark
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/icerbergio-benchmark by this 
push:
     new e9729ae12e4 Update collection name
e9729ae12e4 is described below

commit e9729ae12e433a8f5b709f60fd7a7dfd8fcd9386
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Thu Jul 9 14:03:55 2026 +0400

    Update collection name
---
 it/iceberg/src/test/java/org/apache/beam/it/iceberg/IcebergIOLT.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/it/iceberg/src/test/java/org/apache/beam/it/iceberg/IcebergIOLT.java 
b/it/iceberg/src/test/java/org/apache/beam/it/iceberg/IcebergIOLT.java
index 683ff4529b6..fcc2138775f 100644
--- a/it/iceberg/src/test/java/org/apache/beam/it/iceberg/IcebergIOLT.java
+++ b/it/iceberg/src/test/java/org/apache/beam/it/iceberg/IcebergIOLT.java
@@ -235,7 +235,8 @@ public final class IcebergIOLT extends IOLoadTestBase {
     MetricsConfiguration readMetricsConfig =
         MetricsConfiguration.builder()
             .setOutputPCollection("Counting element.out0")
-            .setOutputPCollectionV2("Counting 
element/ParMultiDo(Counting).out0")
+            .setOutputPCollectionV2(
+                "Read from 
Iceberg/Read(ScanSource)/ParDo(BoundedSourceAsSDFWrapper)/ParMultiDo(BoundedSourceAsSDFWrapper).out0")
             .build();
 
     try {

Reply via email to