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

fix tests

Browse Source
This commit is contained in:
Sema Checherinda 2024-10-03 17:23:32 +02:00
parent 7dab7ae9a4
commit 2280aa5e30
4 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Client/ClientBase.cpp
View File

@ -1474,8 +1474,6 @@ void ClientBase::resetOutput()
out_file_buf->finalize();
out_file_buf.reset();
if (out_logs_buf)
out_logs_buf->finalize();
out_logs_buf.reset();
if (pager_cmd)

2
src/Coordination/KeeperCommon.h
View File

@ -1,7 +1,7 @@
#pragma once
#include <base/StringRef.h>
#include "Common/Logger.h"
#include <Common/Logger.h>
namespace DB
{

2
src/Processors/Transforms/DeduplicationTokenTransforms.h
View File

@ -4,7 +4,7 @@
#include <Processors/ISimpleTransform.h>
#include <base/defines.h>
#include "Common/Logger.h"
#include <Common/Logger.h>
namespace DB

8
src/Server/TCPHandler.cpp
View File

@ -686,15 +686,17 @@ void TCPHandler::runImpl()
if (state.empty() || state.cancellation_status == CancellationStatus::FULLY_CANCELLED)
{
state.cancelOut();
state.reset();
break;
}
else
{
state.finalizeOut();
}
/// QueryState should be cleared before QueryScope, since otherwise
/// the MemoryTracker will be wrong for possible deallocations.
/// (i.e. deallocations from the Aggregator with two-level aggregation)
/// Also it resets socket's timeouts.
state.finalizeOut();
state.reset();
last_sent_snapshots = ProfileEvents::ThreadIdToCountersSnapshot{};
query_scope.reset();