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());

Reply via email to