diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go
index 32113fb456..5c5ed1a188 100644
--- a/flow/connectors/s3/s3.go
+++ b/flow/connectors/s3/s3.go
@@ -94,8 +94,8 @@ func (c *S3Connector) InitializeTableSchema(req map[string]*protos.TableSchema)
 }
 
 func (c *S3Connector) Close() error {
-	log.Debugf("Closing s3 connector is a noop")
-	return nil
+	log.Debugf("Closing metadata store connection")
+	return c.pgMetadata.Close()
 }
 
 func ValidCheck(s3Client *s3.S3, bucketURL string, metadataDB *metadataStore.PostgresMetadataStore) error {