From 6649f6dc6f4341bdb2d0fc7fd532dc1cfa2bc495 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Wed, 27 Dec 2023 14:58:20 -0500
Subject: [PATCH] add batch id in clustering as well

---
 flow/connectors/bigquery/bigquery.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
index 92a3426bab..3245f84a47 100644
--- a/flow/connectors/bigquery/bigquery.go
+++ b/flow/connectors/bigquery/bigquery.go
@@ -678,6 +678,7 @@ func (c *BigQueryConnector) CreateRawTable(req *protos.CreateRawTableInput) (*pr
 
 	clustering := &bigquery.Clustering{
 		Fields: []string{
+			"_peerdb_batch_id",
 			"_peerdb_destination_table_name",
 			"_peerdb_timestamp",
 		},