Fix for restart on connection lost

ianton-ru · ianton-ru · commit 02517d71924e · 2025-10-03T14:31:43.000+02:00
diff --git a/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp b/src/QueryPipeline/RemoteQueryExecutorReadContext.cpp
@@ -101,6 +101,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();
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -101,6 +101,7 @@ void RemoteQueryExecutorReadContext::Task::run(AsyncCallback async_callback, Sus`
`101`	`101`	`throw;`
`102`	`102`	`read_context.packet.type = Protocol::Server::ConnectionLost;`
`103`	`103`	`read_context.packet.exception = std::make_unique<Exception>(getCurrentExceptionMessageAndPattern(true), getCurrentExceptionCode());`
	`104`	`+ read_context.has_read_packet_part = PacketPart::Body;`
`104`	`105`	`suspend_callback();`
`105`	`106`	`}`
`106`	`107`	`}`