mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-17 11:52:27 +00:00
Hard cancel for pipeline executor
This commit is contained in:
parent
e424ad9ba8
commit
5aabfe8644
@ -148,7 +148,7 @@ bool PipelineExecutor::checkTimeLimitSoft()
|
||||
// We call cancel here so that all processors are notified and tasks waken up
|
||||
// so that the "break" is faster and doesn't wait for long events
|
||||
if (!continuing)
|
||||
cancel();
|
||||
cancel(/*hard_cancel*/ true);
|
||||
|
||||
return continuing;
|
||||
}
|
||||
@ -229,7 +229,7 @@ void PipelineExecutor::executeStepImpl(size_t thread_num, std::atomic_bool * yie
|
||||
break;
|
||||
|
||||
if (!context.executeTask())
|
||||
cancel();
|
||||
cancel(/*hard_cancel*/ true);
|
||||
|
||||
if (tasks.isFinished())
|
||||
break;
|
||||
|
Loading…
Reference in New Issue
Block a user