From d61f6c10695e463556523b3a865514ede390a960 Mon Sep 17 00:00:00 2001 From: Alexey Milovidov Date: Tue, 16 Oct 2012 18:41:35 +0000 Subject: [PATCH] dbms: addition to prev. revision [#CONV-2944]. --- dbms/include/DB/DataStreams/RemoteBlockInputStream.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbms/include/DB/DataStreams/RemoteBlockInputStream.h b/dbms/include/DB/DataStreams/RemoteBlockInputStream.h index 16e7a9ac382..a88cc14659b 100644 --- a/dbms/include/DB/DataStreams/RemoteBlockInputStream.h +++ b/dbms/include/DB/DataStreams/RemoteBlockInputStream.h @@ -52,7 +52,7 @@ public: if (progress_callback) progress_callback(packet.progress.rows, packet.progress.bytes); - if (is_cancelled_callback && is_cancelled_callback()) + if (!cancelled && is_cancelled_callback && is_cancelled_callback()) { LOG_TRACE(log, "Cancelling query");