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

temp-commit

Browse Source
This commit is contained in:
Konstantin Bogdanov 2024-09-13 18:40:28 +02:00
parent e3dd7b6668
commit c40dae940e
No known key found for this signature in database
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Server/HTTPHandler.cpp
View File

@ -542,7 +542,7 @@ void HTTPHandler::processQuery(
applyHTTPResponseHeaders(response, http_response_headers_override);
auto set_query_result = [&response, this] (const QueryResultDetails & details)
auto set_query_result = [&response, &used_output, this] (const QueryResultDetails & details)
{
response.add("X-ClickHouse-Query-Id", details.query_id);
@ -555,6 +555,10 @@ void HTTPHandler::processQuery(
if (details.timezone)
response.add("X-ClickHouse-Timezone", *details.timezone);
/// Start sending headers early, as it requires access to the internal
/// WriteBuffer, which may also be used concurrently by compressing wrapper.
used_output.out_holder->startSendHeadersPublic();
};
auto handle_exception_in_output_format = [&](IOutputFormat & current_output_format, const String & format_name, const ContextPtr & context_, const std::optional<FormatSettings> & format_settings)
@ -587,10 +591,6 @@ void HTTPHandler::processQuery(
}
};
/// Start sending headers early, as it requires access to the internal
/// WriteBuffer, which may also be used concurrently by compressing wrapper.
used_output.out_holder->startSendHeadersPublic();
executeQuery(
*in,
*used_output.out_maybe_delayed_and_compressed,