This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new c7c6a37b83b fix test (#36763)
c7c6a37b83b is described below
commit c7c6a37b83bdbfe3a9ab202377bb363023a34601
Author: Radosław Stankiewicz <[email protected]>
AuthorDate: Sat Nov 8 02:04:37 2025 +0100
fix test (#36763)
---
.../org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadIT.java
b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadIT.java
index 742a390c8bd..78ad939bc75 100644
---
a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadIT.java
+++
b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadIT.java
@@ -145,7 +145,7 @@ public class BigQueryIODynamicReadIT {
null, options.getInputTable(), null, null, null,
null)))
.apply(
"Read",
- BigQueryIO.readDynamically(TableRowParser.INSTANCE,
TableRowJsonCoder.of())
+ BigQueryIO.readDynamically(FailingTableRowParser.INSTANCE,
TableRowJsonCoder.of())
.withFormat(options.getDataFormat())
.withBadRecordErrorHandler(errorHandler))
.apply("Count", Count.globally());