From dffaf9b9a5b69ec4e342192ecbf00ad2c90208d8 Mon Sep 17 00:00:00 2001
From: Alexey Milovidov <milovidov@clickhouse.com>
Date: Mon, 21 Oct 2024 03:32:19 +0200
Subject: [PATCH] Fix error

---
 src/Compression/ParallelCompressedWriteBuffer.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Compression/ParallelCompressedWriteBuffer.cpp b/src/Compression/ParallelCompressedWriteBuffer.cpp
index bd8d6371501..08c2a78c80b 100644
--- a/src/Compression/ParallelCompressedWriteBuffer.cpp
+++ b/src/Compression/ParallelCompressedWriteBuffer.cpp
@@ -122,7 +122,7 @@ void ParallelCompressedWriteBuffer::compress(Iterator buffer)
     if (can_write_directly)
     {
         char * out_compressed_ptr = out.position() + sizeof(CityHash_v1_0_2::uint128);
-        UInt32 compressed_size = codec->compress(working_buffer.begin(), uncompressed_size, out_compressed_ptr);
+        UInt32 compressed_size = codec->compress(buffer->uncompressed.data(), uncompressed_size, out_compressed_ptr);
 
         CityHash_v1_0_2::uint128 checksum = CityHash_v1_0_2::CityHash128(out_compressed_ptr, compressed_size);