thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 01:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Review fix

Browse Source
This commit is contained in:
alesapin 2024-02-19 10:32:36 +01:00
parent 29e3e7cb96
commit 6565423b1a
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Storages/StorageBuffer.cpp
View File

@ -5,6 +5,7 @@
#include <Interpreters/evaluateConstantExpression.h>
#include <Interpreters/addMissingDefaults.h>
#include <Interpreters/getColumnFromBlock.h>
#include <Interpreters/threadPoolCallbackRunner.h>
#include <Storages/StorageBuffer.h>
#include <Storages/StorageFactory.h>
#include <Storages/AlterCommands.h>
@ -814,10 +815,10 @@ void StorageBuffer::flushAllBuffers(bool check_thresholds)
{
if (flush_pool)
{
flush_pool->scheduleOrThrowOnError([&] ()
scheduleFromThreadPool<void>([&] ()
{
flushBuffer(buf, check_thresholds, false);
});
}, *flush_pool, "BufferFlush");
}
else
{