From 8a319006da4a3e49a4b6630076a8b1fb6a83ff15 Mon Sep 17 00:00:00 2001
From: Kevin Biju <kevin@peerdb.io>
Date: Mon, 30 Oct 2023 22:30:18 +0530
Subject: [PATCH] close channel for BQ avro writer

---
 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 e4594688ef..7383bac2a6 100644
--- a/flow/connectors/bigquery/bigquery.go
+++ b/flow/connectors/bigquery/bigquery.go
@@ -831,6 +831,7 @@ func (c *BigQueryConnector) syncRecordsViaAvro(
 		}
 	}
 
+	close(recordStream.Records)
 	avroSync := NewQRepAvroSyncMethod(c, req.StagingPath)
 	rawTableMetadata, err := c.client.Dataset(c.datasetID).Table(rawTableName).Metadata(c.ctx)
 	if err != nil {