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: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org