diff --git a/dbms/src/Flash/Mpp/MPPTask.cpp b/dbms/src/Flash/Mpp/MPPTask.cpp
index 200bb273cac..2c6d33676ef 100644
--- a/dbms/src/Flash/Mpp/MPPTask.cpp
+++ b/dbms/src/Flash/Mpp/MPPTask.cpp
@@ -356,6 +356,7 @@ void MPPTask::runImpl()
     }
     else
     {
+        context->getProcessList().sendCancelToQuery(context->getCurrentQueryId(), context->getClientInfo().current_user, true);
         if (dag_context)
             dag_context->cancelAllExchangeReceiver();
         writeErrToAllTunnels(err_msg);