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

fixing tests

Browse Source
This commit is contained in:
Sema Checherinda 2024-06-14 18:32:12 +02:00
parent e4050334bb
commit 99167d3b87
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Client/Connection.cpp
View File

@ -73,7 +73,7 @@ namespace ErrorCodes
Connection::~Connection() Connection::~Connection()
{ {
if (connected) if (connected)
disconnect(); Connection::disconnect();
} }
Connection::Connection(const String & host_, UInt16 port_, Connection::Connection(const String & host_, UInt16 port_,

1
src/Storages/ObjectStorage/HDFS/WriteBufferFromHDFS.cpp
View File

@ -147,6 +147,7 @@ void WriteBufferFromHDFS::finalizeImpl()
WriteBufferFromHDFS::~WriteBufferFromHDFS() WriteBufferFromHDFS::~WriteBufferFromHDFS()
{ {
if (!canceled)
finalize(); finalize();
} }

2
src/Storages/ObjectStorage/StorageObjectStorageSink.cpp
View File

@ -51,8 +51,8 @@ void StorageObjectStorageSink::onCancel()
{ {
std::lock_guard lock(cancel_mutex); std::lock_guard lock(cancel_mutex);
cancelBuffers(); cancelBuffers();
cancelled = true;
releaseBuffers(); releaseBuffers();
cancelled = true;
} }
void StorageObjectStorageSink::onException(std::exception_ptr) void StorageObjectStorageSink::onException(std::exception_ptr)