diff --git a/clients/bigquery/merge.go b/clients/bigquery/merge.go index 213cddcbd..bf807e87b 100644 --- a/clients/bigquery/merge.go +++ b/clients/bigquery/merge.go @@ -51,6 +51,8 @@ func (s *Store) Merge(tableData *optimization.TableData) error { AdditionalEqualityStrings: additionalEqualityStrings, // BigQuery has DDL quotas. RetryColBackfill: true, + // We are using BigQuery's streaming API which doesn't guarantee exactly once semantics + SubQueryDedupe: true, }) }