diff --git a/dbms/src/Storages/Distributed/DistributedBlockOutputStream.cpp b/dbms/src/Storages/Distributed/DistributedBlockOutputStream.cpp index d17b62bb36e..687f3ca1587 100644 --- a/dbms/src/Storages/Distributed/DistributedBlockOutputStream.cpp +++ b/dbms/src/Storages/Distributed/DistributedBlockOutputStream.cpp @@ -374,7 +374,8 @@ void DistributedBlockOutputStream::writeSuffix() { if (job.stream) { - pool->schedule([&job] () { + pool->schedule([&job] () + { job.stream->writeSuffix(); }); }