This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from c0d55b54c0 [Improvement](statistics) Support for statistics removing
and incremental collection (#18069)
add 2ee1468576 [improvement](executor) Support task group schedule in
pipeline engine (#17615)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.h | 1 +
be/src/pipeline/pipeline_fragment_context.cpp | 6 +-
be/src/pipeline/pipeline_fragment_context.h | 2 +
be/src/pipeline/pipeline_task.cpp | 30 +++-
be/src/pipeline/pipeline_task.h | 9 +-
be/src/pipeline/task_queue.cpp | 183 +++++++++++++++++++--
be/src/pipeline/task_queue.h | 104 +++++++++---
be/src/pipeline/task_scheduler.cpp | 6 +-
be/src/pipeline/task_scheduler.h | 1 +
be/src/runtime/CMakeLists.txt | 2 +
be/src/runtime/exec_env.h | 5 +
be/src/runtime/exec_env_init.cpp | 11 +-
be/src/runtime/fragment_mgr.cpp | 164 ++++++------------
be/src/runtime/fragment_mgr.h | 4 +
be/src/runtime/query_fragments_ctx.h | 7 +
be/src/runtime/task_group/task_group.cpp | 65 ++++++++
be/src/runtime/task_group/task_group.h | 82 +++++++++
be/src/runtime/task_group/task_group_manager.cpp | 52 ++++++
.../task_group/task_group_manager.h} | 40 +++--
regression-test/pipeline/p0/conf/be.conf | 2 +-
regression-test/pipeline/p1/conf/be.conf | 2 +-
21 files changed, 606 insertions(+), 172 deletions(-)
create mode 100644 be/src/runtime/task_group/task_group.cpp
create mode 100644 be/src/runtime/task_group/task_group.h
create mode 100644 be/src/runtime/task_group/task_group_manager.cpp
copy be/src/{agent/topic_subscriber.h =>
runtime/task_group/task_group_manager.h} (55%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
