diff --git a/dbms/include/DB/DataStreams/RemoteBlockInputStream.h b/dbms/include/DB/DataStreams/RemoteBlockInputStream.h
index 0acafa906c2..6a39f5a7b83 100644
--- a/dbms/include/DB/DataStreams/RemoteBlockInputStream.h
+++ b/dbms/include/DB/DataStreams/RemoteBlockInputStream.h
@@ -147,6 +147,7 @@ protected:
 			createParallelReplicas();
 			parallel_replicas->sendQuery(query, "", stage, true);
 			sendExternalTables();
+			__sync_synchronize();
 			sent_query = true;
 		}