diff --git a/src/Interpreters/ConcurrentHashJoin.cpp b/src/Interpreters/ConcurrentHashJoin.cpp index fee3616a697..83137da1bf3 100644 --- a/src/Interpreters/ConcurrentHashJoin.cpp +++ b/src/Interpreters/ConcurrentHashJoin.cpp @@ -83,9 +83,7 @@ bool ConcurrentHashJoin::addJoinedBlock(const Block & block, bool check_limits) iter = pending_blocks.erase(iter); } else - { iter++; - } } }