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

Fix missing thread accounting for insert_distributed_sync=1

Browse Source 
Signed-off-by: Azat Khuzhin <a.khuzhin@semrush.com>
This commit is contained in:
Azat Khuzhin 2023-10-09 15:41:52 +02:00
parent 807cf893e8
commit 5d2a97106c
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Storages/Distributed/DistributedSink.cpp
View File

@ -553,8 +553,15 @@ void DistributedSink::onFinish()
{
if (job.executor)
{
pool->scheduleOrThrowOnError([&job]()
pool->scheduleOrThrowOnError([&job, thread_group = CurrentThread::getGroup()]()
{
SCOPE_EXIT_SAFE(
if (thread_group)
CurrentThread::detachFromGroupIfNotDetached();
);
if (thread_group)
CurrentThread::attachToGroupIfDetached(thread_group);
job.executor->finish();
});
}