This commit is contained in:
lgbo-ustc 2022-04-27 16:41:34 +08:00
parent 7505ce426a
commit 10b7e08319

View File

@ -83,9 +83,11 @@ bool ConcurrentHashJoin::addJoinedBlock(const Block & block, bool check_limits)
iter = pending_blocks.erase(iter);
}
else
{
iter++;
}
}
}
if (check_limits)
return table_join->sizeLimits().check(getTotalRowCount(), getTotalByteCount(), "JOIN", ErrorCodes::SET_SIZE_LIMIT_EXCEEDED);