提交 417dc433 编写于 作者: A Azat Khuzhin

Fix thread group for ParallelParsingBlockInputStream after removing std::bind

上级 a5885b47
......@@ -63,9 +63,9 @@ void ParallelParsingBlockInputStream::cancel(bool kill)
void ParallelParsingBlockInputStream::scheduleParserThreadForUnitWithNumber(size_t ticket_number)
{
pool.scheduleOrThrowOnError([this, ticket_number]()
pool.scheduleOrThrowOnError([this, ticket_number, group = CurrentThread::getGroup()]()
{
parserThreadFunction(CurrentThread::getGroup(), ticket_number);
parserThreadFunction(group, ticket_number);
});
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册