diff --git a/dbms/src/Processors/IProcessor.h b/dbms/src/Processors/IProcessor.h index 87081b89199..3c5db7d5fb9 100644 --- a/dbms/src/Processors/IProcessor.h +++ b/dbms/src/Processors/IProcessor.h @@ -224,8 +224,8 @@ public: bool isCancelled() const { return is_cancelled; } void cancel() { - onCancel(); is_cancelled = true; + onCancel(); } virtual ~IProcessor() = default;