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 {