thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-18 20:32:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix for multiple threads

Browse Source
This commit is contained in:
yariks5s 2024-04-10 22:22:13 +00:00
parent 149e2af369
commit 94eb0782a9
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/Processors/Transforms/BalancingTransform.cpp
View File

@ -53,7 +53,7 @@ IProcessor::Status BalancingChunksTransform::prepareConsume()
return Status::Finished;
}
if (input.isFinished())
if (input.isFinished() && !balance.isDataLeft())
{
for (auto & output : outputs)
output.finish();
@ -117,7 +117,10 @@ IProcessor::Status BalancingChunksTransform::prepareSend()
++chunk_number;
if (!chunk.hasChunkInfo())
throw Exception(ErrorCodes::LOGICAL_ERROR, "Chunk info must be not empty in prepareGenerate()");
{
has_data = false;
return Status::Ready;
}
if (was_processed)
continue;