Skip to content

Commit

Permalink
missing import
Browse files Browse the repository at this point in the history
  • Loading branch information
ahmedabu98 committed Mar 27, 2023
1 parent 10bbcd1 commit 0999c68
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -427,7 +427,7 @@ private void validateSchema(
table = BigQueryHelpers.getTable(options, tableRef);
}
if (table == null) {
LOG.info("Table not found and skipped schema validation: " + tableRef.getTableId());
LOG.info("Table [{}] not found, skipping schema validation.", tableRef.getTableId());
return;
}
Schema outputSchema = BigQueryUtils.fromTableSchema(table.getSchema());
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@
import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.PipelineResult;
import org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers;
import org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils;
import org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiPCollectionRowTupleTransform;
import org.apache.beam.sdk.io.gcp.bigquery.providers.BigQueryStorageWriteApiSchemaTransformProvider.BigQueryStorageWriteApiSchemaTransformConfiguration;
import org.apache.beam.sdk.io.gcp.testing.FakeBigQueryServices;
Expand Down

0 comments on commit 0999c68

Please sign in to comment.