Skip to content

Commit 45f9d25

Browse files
committed
removing fallback input
1 parent 64121a8 commit 45f9d25

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

src/main/java/io/cdap/plugin/gcp/bigquery/source/BigQuerySource.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -345,8 +345,6 @@ private void validatePartitionProperties(FailureCollector collector) {
345345

346346
private void setInputFormat(BatchSourceContext context,
347347
Schema configuredSchema) {
348-
Input inputFormatInput = Input.of(config.referenceName, new BigQueryInputFormatProvider(configuration));
349-
350348
// Add output for SQL Engine Direct read
351349
ImmutableMap.Builder<String, String> arguments = new ImmutableMap.Builder<>();
352350

@@ -360,8 +358,7 @@ private void setInputFormat(BatchSourceContext context,
360358
Input sqlEngineInput = new SQLEngineInput(config.referenceName,
361359
context.getStageName(),
362360
BigQuerySQLEngine.class.getName(),
363-
arguments.build(),
364-
inputFormatInput);
361+
arguments.build());
365362
context.setInput(sqlEngineInput);
366363
}
367364

0 commit comments

Comments
 (0)