Update dbms/src/Flash/Mpp/MPPTaskScheduleEntry.cpp

Co-authored-by: SeaRise <[email protected]>
pingcap · Sep 28, 2022 · 210fe65 · 210fe65
1 parent 353b23c
commit 210fe65
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/dbms/src/Flash/Mpp/MPPTaskScheduleEntry.cpp b/dbms/src/Flash/Mpp/MPPTaskScheduleEntry.cpp
@@ -79,10 +79,7 @@ const MPPTaskId & MPPTaskScheduleEntry::getMPPTaskId() const
 
 int MPPTaskScheduleEntry::getNeededThreads() const
 {
-    if (needed_threads == 0)
-    {
-        throw Exception(" the needed_threads of task " + id.toString() + " is not initialized!");
-    }
+    RUNTIME_CHECK_MSG(needed_threads > 0, "the needed_threads of task {} is not initialized!", id.toString());
     return needed_threads;
 }