Skip to content

Commit

Permalink
fix conflict
Browse files Browse the repository at this point in the history
Signed-off-by: gengliqi <gengliqiii@gmail.com>
  • Loading branch information
gengliqi committed Jul 21, 2022
1 parent 9c5ac0b commit 1b7d589
Showing 1 changed file with 1 addition and 6 deletions.
7 changes: 1 addition & 6 deletions dbms/src/DataStreams/ParallelAggregatingBlockInputStream.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -186,13 +186,8 @@ void ParallelAggregatingBlockInputStream::Handler::onException(std::exception_pt
parent.first_exception_index.compare_exchange_strong(old_value, static_cast<Int32>(thread_num), std::memory_order_seq_cst, std::memory_order_relaxed);

if (!parent.executed)
<<<<<<< HEAD
/// kill the processor so ExchangeReceiver will be closed
parent.processor.cancel(true);
=======
/// use cancel instead of kill to avoid too many useless error message
parent.cancel(false);
>>>>>>> 7b280755ba (fix a panic issue in parallel agg when exception is thrown (#5433))
parent.cancel(true);
}


Expand Down

0 comments on commit 1b7d589

Please sign in to comment.