From c14b0440a1503167d925073019e33a2a82fa8959 Mon Sep 17 00:00:00 2001
From: Radek Stankiewicz <radoslaws@google.com>
Date: Fri, 7 Nov 2025 21:22:22 +0100
Subject: [PATCH] fix test

---
 .../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 742a390c8bd1..78ad939bc754 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 @@ private void runBigQueryIODynamicReadPipelineErrorHandling() throws Exception {
                         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());