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