thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-18 12:22:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

add sendProgress between read blocks

Browse Source
This commit is contained in:
Sema Checherinda 2024-12-06 16:23:30 +01:00
parent 516fd98327
commit 266e854560
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Server/TCPHandler.cpp
View File

@ -37,7 +37,6 @@
#include <Poco/Net/NetException.h> #include <Poco/Net/NetException.h>
#include <Poco/Net/SocketAddress.h> #include <Poco/Net/SocketAddress.h>
#include <Poco/Util/LayeredConfiguration.h> #include <Poco/Util/LayeredConfiguration.h>
#include "Common/StackTrace.h"
#include <Common/Exception.h> #include <Common/Exception.h>
#include <Common/CurrentMetrics.h> #include <Common/CurrentMetrics.h>
#include <Common/CurrentThread.h> #include <Common/CurrentThread.h>
@ -1010,6 +1009,7 @@ void TCPHandler::readData(QueryState & state)
while (receivePacketsExpectData(state)) while (receivePacketsExpectData(state))
{ {
sendProgress(state);
sendLogs(state); sendLogs(state);
sendInsertProfileEvents(state); sendInsertProfileEvents(state);
} }
@ -1114,6 +1114,7 @@ void TCPHandler::processInsertQuery(QueryState & state)
{ {
executor.push(std::move(state.block_for_insert)); executor.push(std::move(state.block_for_insert));
sendProgress(state);
sendLogs(state); sendLogs(state);
sendInsertProfileEvents(state); sendInsertProfileEvents(state);
} }