This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from e1654bc6ef [Enhancement](function) add to_bitmap() function with int
type (#13973)
add 0b945fe361 [enhancement](memtracker) Refactor mem tracker hierarchy
(#13585)
No new revisions were added by this update.
Summary of changes:
be/src/exec/hash_table.cpp | 2 +-
be/src/exec/olap_scan_node.cpp | 2 +-
be/src/exec/partitioned_aggregation_node.cc | 8 +-
be/src/exec/partitioned_hash_table.cc | 2 +-
be/src/exec/tablet_sink.cpp | 6 +-
be/src/exec/tablet_sink.h | 4 +-
be/src/http/default_path_handlers.cpp | 66 ++--
be/src/olap/base_compaction.cpp | 2 +-
be/src/olap/compaction.cpp | 8 +-
be/src/olap/cumulative_compaction.cpp | 2 +-
be/src/olap/delta_writer.cpp | 12 +
be/src/olap/lru_cache.cpp | 2 +-
be/src/olap/memtable.cpp | 2 +-
be/src/olap/olap_server.cpp | 4 +-
be/src/olap/rowset/beta_rowset_writer.cpp | 3 +-
be/src/olap/schema_change.cpp | 4 +-
be/src/olap/storage_engine.cpp | 35 +--
be/src/olap/storage_engine.h | 30 +-
be/src/olap/task/engine_alter_tablet_task.cpp | 6 +-
be/src/olap/task/engine_batch_load_task.cpp | 7 +-
be/src/olap/task/engine_checksum_task.cpp | 6 +-
be/src/olap/task/engine_clone_task.cpp | 6 +-
be/src/runtime/CMakeLists.txt | 1 -
be/src/runtime/buffer_control_block.cpp | 6 +-
be/src/runtime/buffered_block_mgr2.cc | 14 +-
be/src/runtime/data_stream_recvr.cc | 19 +-
be/src/runtime/data_stream_sender.cpp | 15 +-
be/src/runtime/disk_io_mgr.cc | 3 +-
be/src/runtime/exec_env.h | 34 +-
be/src/runtime/exec_env_init.cpp | 69 +----
be/src/runtime/fragment_mgr.cpp | 27 ++
be/src/runtime/load_channel_mgr.cpp | 9 +
be/src/runtime/load_channel_mgr.h | 3 +
be/src/runtime/mem_pool.cpp | 2 +-
be/src/runtime/memory/chunk_allocator.cpp | 3 +-
be/src/runtime/memory/mem_tracker.cpp | 71 ++---
be/src/runtime/memory/mem_tracker.h | 59 ++--
be/src/runtime/memory/mem_tracker_limiter.cpp | 375 ++++++++++-------------
be/src/runtime/memory/mem_tracker_limiter.h | 289 +++++++----------
be/src/runtime/memory/mem_tracker_task_pool.cpp | 162 ----------
be/src/runtime/memory/mem_tracker_task_pool.h | 68 ----
be/src/runtime/memory/system_allocator.cpp | 2 +-
be/src/runtime/memory/thread_mem_tracker_mgr.cpp | 28 +-
be/src/runtime/memory/thread_mem_tracker_mgr.h | 90 ++----
be/src/runtime/plan_fragment_executor.cpp | 7 +-
be/src/runtime/query_fragments_ctx.h | 19 ++
be/src/runtime/runtime_filter_mgr.cpp | 2 +-
be/src/runtime/runtime_state.cpp | 57 +---
be/src/runtime/runtime_state.h | 32 +-
be/src/runtime/sorted_run_merger.cc | 2 +-
be/src/runtime/stream_load/stream_load_pipe.h | 4 +-
be/src/runtime/thread_context.cpp | 25 +-
be/src/runtime/thread_context.h | 97 ++----
be/src/service/doris_main.cpp | 22 +-
be/src/service/internal_service.cpp | 72 ++---
be/src/util/mem_info.cpp | 14 +-
be/src/util/ref_count_closure.h | 1 +
be/src/vec/common/allocator.h | 14 +-
be/src/vec/exec/scan/scanner_scheduler.cpp | 6 +-
be/src/vec/exec/volap_scan_node.cpp | 6 +-
be/src/vec/runtime/vdata_stream_mgr.cpp | 2 +-
be/src/vec/runtime/vdata_stream_recvr.cpp | 24 +-
be/src/vec/runtime/vdata_stream_recvr.h | 5 +-
be/src/vec/sink/vdata_stream_sender.cpp | 6 +-
be/src/vec/sink/vtablet_sink.cpp | 4 +-
be/test/exec/broker_scan_node_test.cpp | 2 +-
be/test/exec/broker_scanner_test.cpp | 2 +-
be/test/exec/es_http_scan_node_test.cpp | 2 +-
be/test/exec/es_predicate_test.cpp | 2 +-
be/test/exec/hash_table_test.cpp | 6 +-
be/test/exec/json_scanner_test.cpp | 2 +-
be/test/exec/json_scanner_with_jsonpath_test.cpp | 2 +-
be/test/exec/orc_scanner_test.cpp | 2 +-
be/test/exec/parquet_scanner_test.cpp | 2 +-
be/test/exec/tablet_sink_test.cpp | 3 -
be/test/exprs/runtime_filter_test.cpp | 2 +-
be/test/olap/lru_cache_test.cpp | 3 +-
be/test/runtime/mem_limit_test.cpp | 96 +-----
be/test/runtime/test_env.cc | 3 -
be/test/testutil/run_all_tests.cpp | 12 +-
be/test/util/arrow/arrow_work_flow_test.cpp | 5 +-
be/test/vec/exec/parquet/parquet_reader_test.cpp | 2 +-
be/test/vec/exec/vbroker_scan_node_test.cpp | 2 +-
be/test/vec/exec/vbroker_scanner_test.cpp | 2 +-
be/test/vec/exec/vjson_scanner_test.cpp | 2 +-
be/test/vec/exec/vorc_scanner_test.cpp | 2 +-
be/test/vec/exec/vparquet_scanner_test.cpp | 2 +-
be/test/vec/exec/vtablet_sink_test.cpp | 3 -
be/test/vec/exprs/vexpr_test.cpp | 4 +-
be/test/vec/runtime/vdata_stream_test.cpp | 2 +-
90 files changed, 720 insertions(+), 1436 deletions(-)
delete mode 100644 be/src/runtime/memory/mem_tracker_task_pool.cpp
delete mode 100644 be/src/runtime/memory/mem_tracker_task_pool.h
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
