From 2e18dba201c8da52cad2515f735a5a4cb5f40838 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Sat, 6 Jan 2024 14:58:33 -0500 Subject: [PATCH] move to 8 --- flow/connectors/bigquery/merge_statement_generator.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/bigquery/merge_statement_generator.go b/flow/connectors/bigquery/merge_statement_generator.go index 8fa6e0dcc7..a7a890a543 100644 --- a/flow/connectors/bigquery/merge_statement_generator.go +++ b/flow/connectors/bigquery/merge_statement_generator.go @@ -124,7 +124,7 @@ func (m *mergeStmtGenerator) generateDeDupedCTE() string { func (m *mergeStmtGenerator) generateMergeStmts() []string { // TODO (kaushik): This is so that the statement size for individual merge statements // doesn't exceed the limit. We should make this configurable. - const batchSize = 16 + const batchSize = 8 partitions := utils.ArrayPartition(m.unchangedToastColumns, batchSize) mergeStmts := make([]string, 0, len(partitions))