From 4a66a8c1032ce29041216864d4fe98257dcadea4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Thu, 14 Nov 2024 21:12:12 +0000 Subject: [PATCH] post rebase fix --- flow/connectors/clickhouse/normalize.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/clickhouse/normalize.go b/flow/connectors/clickhouse/normalize.go index c8d2f0a09..fb221096c 100644 --- a/flow/connectors/clickhouse/normalize.go +++ b/flow/connectors/clickhouse/normalize.go @@ -305,7 +305,7 @@ func (c *ClickHouseConnector) NormalizeRecords( chConn = c.database } else { var err error - chConn, err = Connect(errCtx, c.config) + chConn, err = Connect(errCtx, req.Env, c.config) if err != nil { return err }