From d05115be9d946309ed8d42d622dc7f2316765353 Mon Sep 17 00:00:00 2001 From: xufei Date: Thu, 23 Jun 2022 10:36:29 +0800 Subject: [PATCH] add comments Signed-off-by: xufei --- dbms/src/Flash/Mpp/MPPTask.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/dbms/src/Flash/Mpp/MPPTask.cpp b/dbms/src/Flash/Mpp/MPPTask.cpp index 1e85bf15a81..cc52c111ff6 100644 --- a/dbms/src/Flash/Mpp/MPPTask.cpp +++ b/dbms/src/Flash/Mpp/MPPTask.cpp @@ -478,6 +478,9 @@ void MPPTask::abort(const String & message, AbortType abort_type) } else if (previous_status == RUNNING && switchStatus(RUNNING, next_task_status)) { + /// abort the components from top to bottom because if bottom components are aborted + /// first, the top components may see an error caused by the abort, which is not + /// the original error abortTunnels(message, abort_type); abortDataStreams(abort_type); abortReceivers();