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

PostgreSQL source support cancel

Browse Source
This commit is contained in:
Maksim Kita 2024-06-26 16:24:00 +03:00
parent adb40eb701
commit b97ac72be0
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/Processors/Sources/PostgreSQLSource.cpp
View File

@ -120,7 +120,7 @@ Chunk PostgreSQLSource<T>::generate()
MutableColumns columns = description.sample_block.cloneEmptyColumns();
size_t num_rows = 0;
while (true)
while (!isCancelled())
{
const std::vector<pqxx::zview> * row{stream->read_row()};