Skip to content

Commit c7c6a37

Browse files
authored
fix test (#36763)
1 parent c750f8a commit c7c6a37

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -145,7 +145,7 @@ private void runBigQueryIODynamicReadPipelineErrorHandling() throws Exception {
145145
null, options.getInputTable(), null, null, null, null)))
146146
.apply(
147147
"Read",
148-
BigQueryIO.readDynamically(TableRowParser.INSTANCE, TableRowJsonCoder.of())
148+
BigQueryIO.readDynamically(FailingTableRowParser.INSTANCE, TableRowJsonCoder.of())
149149
.withFormat(options.getDataFormat())
150150
.withBadRecordErrorHandler(errorHandler))
151151
.apply("Count", Count.globally());

0 commit comments

Comments
 (0)