Skip to content

Commit

Permalink
This is an automated cherry-pick of pingcap#5433
Browse files Browse the repository at this point in the history
Signed-off-by: ti-chi-bot <ti-community-prow-bot@tidb.io>
  • Loading branch information
gengliqi authored and ti-chi-bot committed Jul 21, 2022
1 parent a859794 commit 9c5ac0b
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion dbms/src/DataStreams/ParallelAggregatingBlockInputStream.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -185,10 +185,14 @@ void ParallelAggregatingBlockInputStream::Handler::onException(std::exception_pt
Int32 old_value = -1;
parent.first_exception_index.compare_exchange_strong(old_value, static_cast<Int32>(thread_num), std::memory_order_seq_cst, std::memory_order_relaxed);

/// can not cancel parent inputStream or the exception might be lost
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))
}


Expand Down

0 comments on commit 9c5ac0b

Please sign in to comment.