diff --git a/dbms/src/Server/TCPHandler.cpp b/dbms/src/Server/TCPHandler.cpp
index c70ddb26dc7..d3aefa14097 100644
--- a/dbms/src/Server/TCPHandler.cpp
+++ b/dbms/src/Server/TCPHandler.cpp
@@ -124,8 +124,10 @@ void TCPHandler::processInsertQuery()
 	Block block = state.io.out_sample;
 	sendData(block);
 
+	state.io.out->writePrefix();
 	while (receivePacket())
 		;
+	state.io.out->writeSuffix();
 }