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

fix

Browse Source
This commit is contained in:
Nikita Taranov 2024-10-23 15:07:49 +01:00
parent d8f2540b3c
commit 69e9dd9b3d
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Interpreters/ConcurrentHashJoin.cpp
View File

@ -246,8 +246,13 @@ void ConcurrentHashJoin::joinBlock(Block & block, std::vector<Block> & res, std:
chassert(res.empty());
res.clear();
res.reserve(dispatched_blocks.size());
std::ranges::transform(
dispatched_blocks, std::back_inserter(res), [](ScatteredBlock & res_block) { return std::move(res_block).getSourceBlock(); });
for (auto && res_block : dispatched_blocks)
{
if (res_block.rows())
res.emplace_back(std::move(res_block).getSourceBlock());
}
if (res.empty())
res.emplace_back(dispatched_blocks[0].getSourceBlock());
}
void ConcurrentHashJoin::checkTypesOfKeys(const Block & block) const