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",
 		},