thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 01:22:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix SIGSEGV in StorageKafka when broker is unavailable

Browse Source
This commit is contained in:
Azat Khuzhin 2020-07-22 11:28:07 +03:00
parent 58ba72c7b6
commit e2d9176617
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Storages/Kafka/KafkaBlockInputStream.h
View File

@ -35,7 +35,7 @@ public:
void readSuffixImpl() override;
void commit();
bool isStalled() const { return buffer->isStalled(); }
bool isStalled() const { return !buffer || buffer->isStalled(); }
private:
StorageKafka & storage;