thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 09:10:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Pass stream_cancelled to the copyData as stub in StorageKafka

Browse Source
This commit is contained in:
Azat Khuzhin 2020-05-03 15:49:40 +03:00
parent c69217e9f3
commit a10cfc3ae5
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Storages/Kafka/StorageKafka.cpp
View File

@ -380,8 +380,7 @@ bool StorageKafka::streamToViews()
else
in = streams[0];
std::atomic<bool> stub = {false};
copyData(*in, *block_io.out, &stub);
copyData(*in, *block_io.out, &stream_cancelled);
for (auto & stream : streams)
stream->as<KafkaBlockInputStream>()->commit();