diff --git a/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp b/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp
index 0e3fb4952eb4..53d292cdef06 100644
--- a/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp
+++ b/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp
@@ -81,6 +81,7 @@ void RemoteQueryExecutorReadContext::Task::run(AsyncCallback async_callback, Sus
             throw;
         read_context.packet.type = Protocol::Server::ConnectionLost;
         read_context.packet.exception = std::make_unique<Exception>(getCurrentExceptionMessageAndPattern(true), getCurrentExceptionCode());
+        read_context.has_read_packet_part = PacketPart::Body;
         suspend_callback();
     }
 }