You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by yh...@apache.org on 2025/11/08 01:04:44 UTC
(beam) branch master updated: fix test (#36763)
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 <ra...@google.com>
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());