diff --git a/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp b/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp index 0c84e844cb2..35373001b28 100644 --- a/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp +++ b/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp @@ -114,9 +114,9 @@ bool RemoteQueryExecutorReadContext::checkTimeout(bool blocking) catch (DB::Exception & e) { if (last_used_socket) - e.addMessage(" while reading from socket ({})", last_used_socket->peerAddress().toString()); + e.addMessage("while reading from socket ({})", last_used_socket->peerAddress().toString()); if (e.code() == ErrorCodes::SOCKET_TIMEOUT) - e.addMessage(" (receive timeout {} ms)", receive_timeout_usec / 1000); + e.addMessage("(receive timeout is {} ms)", receive_timeout_usec / 1000); throw; } } diff --git a/src/Storages/PartitionedSink.h b/src/Storages/PartitionedSink.h index 652d8a4c046..c4bf9c0622c 100644 --- a/src/Storages/PartitionedSink.h +++ b/src/Storages/PartitionedSink.h @@ -45,7 +45,6 @@ private: Arena partition_keys_arena; SinkPtr getSinkForPartitionKey(StringRef partition_key); - }; }