From a2e3813306be2aeca6e392daff6646a4b111dff1 Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Wed, 14 Feb 2024 19:28:31 +0530 Subject: [PATCH] change to error log --- flow/connectors/bigquery/bigquery.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go index 3f598fc6b6..a023202c02 100644 --- a/flow/connectors/bigquery/bigquery.go +++ b/flow/connectors/bigquery/bigquery.go @@ -636,7 +636,7 @@ func (c *BigQueryConnector) NormalizeRecords(req *model.NormalizeRecordsRequest) for _, tableName := range distinctTableNames { normalizeTableSchema := req.TableNameSchemaMapping[tableName] if len(normalizeTableSchema.PrimaryKeyColumns) == 0 { - c.logger.Info(fmt.Sprintf("skipping merge for table %s as it has no primary key", tableName)) + c.logger.Error(fmt.Sprintf("skipping merge for table %s as it has no primary key", tableName)) continue } unchangedToastColumns := tableNametoUnchangedToastCols[tableName]