thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-24 18:50:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Unblock waiting mutations

Browse Source
This commit is contained in:
alesapin 2020-03-18 11:53:55 +03:00
parent 17e505da0f
commit 87e9a84ef7
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dbms/src/Storages/StorageMergeTree.cpp
View File

@ -122,6 +122,9 @@ void StorageMergeTree::shutdown()
merger_mutator.merges_blocker.cancelForever();
parts_mover.moves_blocker.cancelForever();
/// Unlock all waiting mutations
mutation_wait_event.notify_all();
if (merging_mutating_task_handle)
global_context.getBackgroundPool().removeTask(merging_mutating_task_handle);