diff --git a/clickhouse.go b/clickhouse.go index 73019f4a3f..a565247aaa 100644 --- a/clickhouse.go +++ b/clickhouse.go @@ -349,6 +349,7 @@ func (ch *clickhouse) release(conn *connect, err error) { } if ch.opt.FreeBufOnConnRelease { conn.buffer = new(chproto.Buffer) + conn.compressor.Data = nil } select { case ch.idle <- conn: