提交 d4a724dc 编写于 作者: A Alexey Milovidov

Fixed build

上级 0b732576
......@@ -2904,13 +2904,17 @@ void StorageReplicatedMergeTree::startup()
/// If we don't separate create/start steps, race condition will happen
/// between the assignment of queue_task_handle and queueTask that use the queue_task_handle.
queue_task_handle = global_context.getBackgroundPool().createTask([this] { return queueTask(); });
queue_task_handle->startTask();
{
auto & pool = global_context.getBackgroundPool();
queue_task_handle = pool.createTask([this] { return queueTask(); });
pool.startTask(queue_task_handle);
}
if (areBackgroundMovesNeeded())
{
move_parts_task_handle = global_context.getBackgroundMovePool().createTask([this] { return movePartsTask(); });
move_parts_task_handle->startTask();
auto & pool = global_context.getBackgroundMovePool();
move_parts_task_handle = pool.createTask([this] { return movePartsTask(); });
pool.startTask(move_parts_task_handle);
}
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册