diff --git a/be/src/pipeline/pipeline_task.cpp b/be/src/pipeline/pipeline_task.cpp index 7aca64bf09d748..8ebf22494f980f 100644 --- a/be/src/pipeline/pipeline_task.cpp +++ b/be/src/pipeline/pipeline_task.cpp @@ -408,10 +408,12 @@ Status PipelineTask::execute(bool* done) { } }); + SCOPED_RAW_TIMER(&time_spent); RETURN_IF_ERROR(_open()); } while (!fragment_context->is_canceled()) { + SCOPED_RAW_TIMER(&time_spent); Defer defer {[&]() { // If this run is pended by a spilling request, the block will be output in next run. if (!_spilling) {