From f65b582fbc7acf48fdd37e47734edc70452663a3 Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Mon, 30 Oct 2023 08:55:19 -0400
Subject: [PATCH] fix test failures

---
 flow/connectors/bigquery/bigquery.go | 1 -
 flow/connectors/s3/s3.go             | 1 -
 2 files changed, 2 deletions(-)

diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
index 6763e507b1..cd3fda829d 100644
--- a/flow/connectors/bigquery/bigquery.go
+++ b/flow/connectors/bigquery/bigquery.go
@@ -835,7 +835,6 @@ 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 {
diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go
index 8d141d2aa7..0179b3c2e7 100644
--- a/flow/connectors/s3/s3.go
+++ b/flow/connectors/s3/s3.go
@@ -155,7 +155,6 @@ func (c *S3Connector) SyncRecords(req *model.SyncRecordsRequest) (*model.SyncRes
 	partition := &protos.QRepPartition{
 		PartitionId: fmt.Sprint(syncBatchID),
 	}
-	close(recordStream.Records)
 	numRecords, err := c.SyncQRepRecords(qrepConfig, partition, recordStream)
 	if err != nil {
 		return nil, err