This is an automated email from the ASF dual-hosted git repository.
wangbo pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from e716658fbad [branch-2.1](arrow-flight-sql) Fix exceed user property
max connection cause Reach limit of connections (#39836)
add 6ceb574aa0c [branch-2.1]Pick IO limit/workload group usage table
(#39839)
No new revisions were added by this update.
Summary of changes:
be/src/agent/workload_group_listener.cpp | 3 +
be/src/exec/schema_scanner.cpp | 3 +
.../schema_scanner/schema_backend_active_tasks.cpp | 2 +-
...hema_workload_group_resource_usage_scanner.cpp} | 50 +++++++------
...schema_workload_group_resource_usage_scanner.h} | 12 +--
.../schema_workload_groups_scanner.cpp | 2 +
be/src/io/fs/buffered_reader.cpp | 20 +++--
be/src/io/fs/file_reader.cpp | 2 +
be/src/io/fs/file_reader.h | 4 +
be/src/io/fs/hdfs_file_reader.cpp | 4 +
be/src/io/fs/local_file_reader.cpp | 54 ++++++++++++++
be/src/io/fs/local_file_reader.h | 19 +++++
be/src/io/fs/s3_file_reader.cpp | 4 +
be/src/olap/olap_common.h | 8 ++
be/src/pipeline/pipeline_task.cpp | 1 +
be/src/runtime/exec_env.h | 2 +-
be/src/runtime/exec_env_init.cpp | 9 ++-
be/src/runtime/query_context.h | 6 ++
be/src/runtime/thread_context.h | 59 ++++++++++++++-
be/src/runtime/workload_group/workload_group.cpp | 76 ++++++++++++++++++-
be/src/runtime/workload_group/workload_group.h | 33 ++++++++
.../workload_group/workload_group_manager.cpp | 47 ++++++++++++
.../workload_group/workload_group_manager.h | 6 ++
be/src/runtime/workload_management/io_throttle.cpp | 87 ++++++++++++++++++++++
.../io_throttle.h} | 52 ++++++-------
be/src/vec/exec/scan/vscanner.cpp | 9 +++
be/src/vec/exec/scan/vscanner.h | 6 +-
be/src/vec/sink/writer/async_result_writer.cpp | 7 ++
.../org/apache/doris/analysis/SchemaTableType.java | 5 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 12 +++
.../planner/BackendPartitionedSchemaScanNode.java | 1 +
.../resource/workloadgroup/WorkloadGroup.java | 52 ++++++++++++-
.../resource/workloadgroup/WorkloadGroupMgr.java | 1 +
.../doris/tablefunction/MetadataGenerator.java | 7 +-
gensrc/thrift/Descriptors.thrift | 3 +-
.../data/workload_manager_p0/test_curd_wlg.out | 8 +-
.../workload_manager_p0/test_curd_wlg.groovy | 28 ++++++-
37 files changed, 616 insertions(+), 88 deletions(-)
copy be/src/exec/schema_scanner/{schema_file_cache_statistics.cpp =>
schema_workload_group_resource_usage_scanner.cpp} (56%)
copy be/src/exec/schema_scanner/{schema_file_cache_statistics.h =>
schema_workload_group_resource_usage_scanner.h} (80%)
create mode 100644 be/src/runtime/workload_management/io_throttle.cpp
copy be/src/runtime/{broker_mgr.h => workload_management/io_throttle.h} (53%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
