diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go index e9f4fd114c..2ae79fcdae 100644 --- a/flow/connectors/bigquery/bigquery.go +++ b/flow/connectors/bigquery/bigquery.go @@ -175,7 +175,7 @@ func TableCheck(ctx context.Context, client *bigquery.Client, dataset string) er // Drop the table deleteErr := newTable.Delete(ctx) if deleteErr != nil { - errs = append(errs, fmt.Errorf("unable to delete table :%w. ", deleteErr)) + errs = append(errs, fmt.Errorf("unable to delete table: %w. ", deleteErr)) } if len(errs) > 0 {