[pipeline](schedule) Add profile for except node and fix steal task problem (#15282)

2022-12-22 22:42:37 +08:00
parent e331e0420b
commit 388df291af
7 changed files with 12 additions and 5 deletions
--- a/be/src/pipeline/task_queue.cpp
+++ b/be/src/pipeline/task_queue.cpp
@ -166,7 +166,7 @@ PipelineTask* TaskQueue::steal_take(size_t core_id) {
            next_id = 0;
        }
        DCHECK(next_id < _core_size);
-        auto task = _async_queue[core_id].try_take();
+        auto task = _async_queue[next_id].try_take();
        if (task) {
            return task;
        }