From 35f2d914dc805d8295ab9a7d0d3470dbee44a62d Mon Sep 17 00:00:00 2001 From: Maksim Kita Date: Wed, 13 Oct 2021 00:15:05 +0300 Subject: [PATCH] Fixed build --- src/DataStreams/RemoteQueryExecutor.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/DataStreams/RemoteQueryExecutor.cpp b/src/DataStreams/RemoteQueryExecutor.cpp index 08d3db748b7..b6a5e6f63d0 100644 --- a/src/DataStreams/RemoteQueryExecutor.cpp +++ b/src/DataStreams/RemoteQueryExecutor.cpp @@ -35,6 +35,7 @@ namespace ErrorCodes extern const int LOGICAL_ERROR; extern const int UNKNOWN_PACKET_FROM_SERVER; extern const int DUPLICATED_PART_UUIDS; + extern const int SYSTEM_ERROR; } RemoteQueryExecutor::RemoteQueryExecutor( @@ -396,7 +397,8 @@ std::optional RemoteQueryExecutor::processPacket(Packet packet) case Protocol::Server::ProfileEvents: /// Pass profile events from remote server to client if (auto profile_queue = CurrentThread::getInternalProfileEventsQueue()) - profile_queue->emplace(std::move(packet.block)); + if (!profile_queue->emplace(std::move(packet.block))) + throw Exception(ErrorCodes::SYSTEM_ERROR, "Could not push into profile queue"); break; default: