wangbo opened a new pull request, #50236:
URL: https://github.com/apache/doris/pull/50236
TaskQueue should be released after all theads stop.
```
=================================================================
==6632==ERROR: AddressSanitizer: heap-use-after-free on address
0x61700518d440 at pc 0x5616fa5c2a87 bp 0x7f7635b709b0 sp 0x7f7635b709a8
READ of size 8 at 0x61700518d440 thread T5188 (Pipe_test_follo)
#0 0x5616fa5c2a86 in std::__atomic_base<unsigned
long>::load(std::memory_order) const
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:481:9
#1 0x5616fa5c2a86 in std::__atomic_base<unsigned long>::operator
unsigned long() const
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:341:16
#2 0x5616fa5c2a86 in
doris::pipeline::PriorityTaskQueue::_try_take_unprotected(bool)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_queue.cpp:58:9
#3 0x5616fa5c2e16 in doris::pipeline::PriorityTaskQueue::take(unsigned
int)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_queue.cpp:110:16
#4 0x5616fa5c4b06 in doris::pipeline::MultiCoreTaskQueue::take(int)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_queue.cpp:170:51
#5 0x5616fa5d1919 in doris::pipeline::TaskScheduler::_do_work(unsigned
long)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_scheduler.cpp:267:35
#6 0x5616d1e169f8 in doris::ThreadPool::dispatch_thread()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/threadpool.cpp:544:24
#7 0x5616d1df3e38 in std::function<void ()>::operator()() const
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:560:9
#8 0x5616d1df3e38 in doris::Thread::supervise_thread(void*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/thread.cpp:498:5
#9 0x7f83a4c35ac2 in start_thread nptl/pthread_create.c:442:8
#10 0x7f83a4cc784f misc/../sysdeps/unix/sysv/linux/x86_64/clone3.S:81
0x61700518d440 is located 704 bytes inside of 728-byte region
[0x61700518d180,0x61700518d458)
freed by thread T2166 here:
#0 0x5616cea38d9d in operator delete(void*)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x16dc0d9d)
(BuildId: 09b7b6856fee4f7f)
#1 0x5616fa5cae77 in
std::default_delete<doris::pipeline::PriorityTaskQueue>::operator()(doris::pipeline::PriorityTaskQueue*)
const
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/unique_ptr.h:85:2
#2 0x5616fa5cae77 in std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>::~unique_ptr()
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/unique_ptr.h:361:4
#3 0x5616fa5cae77 in void
std::destroy_at<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>(std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/stl_construct.h:88:15
#4 0x5616fa5cae77 in void
std::_Destroy<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>(std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/stl_construct.h:138:7
#5 0x5616fa5cae77 in void
std::_Destroy_aux<false>::__destroy<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*>(std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*,
std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/stl_construct.h:152:6
#6 0x5616fa5cae77 in void
std::_Destroy<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*>(std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*,
std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/stl_construct.h:184:7
#7 0x5616fa5cae77 in void
std::_Destroy<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*,
std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>(std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*,
std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>*,
std::allocator<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/alloc_traits.h:746:7
#8 0x5616fa5cae77 in
std::vector<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>,
std::allocator<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>>::~vector()
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/stl_vector.h:680:2
#9 0x5616fa5c466d in
std::_Sp_counted_base<(__gnu_cxx::_Lock_policy)2>::_M_release()
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:168:6
#10 0x5616fa5c466d in
std::__shared_count<(__gnu_cxx::_Lock_policy)2>::~__shared_count()
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:702:11
#11 0x5616fa5c466d in
std::__shared_ptr<std::vector<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>,
std::allocator<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>>,
(__gnu_cxx::_Lock_policy)2>::~__shared_ptr()
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:1149:31
#12 0x5616fa5c466d in void
std::atomic_store<std::vector<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>,
std::allocator<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>>>(std::shared_ptr<std::vector<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>,
std::allocator<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>>>*,
std::shared_ptr<std::vector<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>,
std::allocator<std::unique_ptr<doris::pipeline::PriorityTaskQueue,
std::default_delete<doris::pipeline::PriorityTaskQueue>>>>>)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_atomic.h:149:7
#13 0x5616fa5c466d in doris::pipeline::MultiCoreTaskQueue::close()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_queue.cpp:151:5
#14 0x5616fa5ce9f4 in doris::pipeline::TaskScheduler::stop()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_scheduler.cpp:437:26
#15 0x5616d19b7d36 in doris::WorkloadGroup::try_stop_schedulers()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/runtime/workload_group/workload_group.cpp:654:22
#16 0x5616d19c6042 in
doris::WorkloadGroupMgr::delete_workload_group_by_ids(std::set<unsigned long,
std::less<unsigned long>, std::allocator<unsigned long>>)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/runtime/workload_group/workload_group_manager.cpp:107:13
#17 0x5616d1a7f6a1 in
doris::WorkloadGroupListener::handle_topic_info(std::vector<doris::TopicInfo,
std::allocator<doris::TopicInfo>> const&)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/agent/workload_group_listener.cpp:82:38
#18 0x5616d1a7dd7e in
doris::TopicSubscriber::handle_topic_info(doris::TPublishTopicRequest const&)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/agent/topic_subscriber.cpp:45:35
#19 0x5616d2002932 in
doris::BackendServiceProcessor::process_publish_topic_info(int,
apache::thrift::protocol::TProtocol*, apache::thrift::protocol::TProtocol*,
void*)
/home/zcp/repo_center/doris_branch-2.1/doris/gensrc/build/gen_cpp/BackendService.cpp:6577:13
#20 0x5616d1fd6f11 in
doris::BackendServiceProcessor::dispatchCall(apache::thrift::protocol::TProtocol*,
apache::thrift::protocol::TProtocol*, std::__cxx11::basic_string<char,
std::char_traits<char>, std::allocator<char>> const&, int, void*)
/home/zcp/repo_center/doris_branch-2.1/doris/gensrc/build/gen_cpp/BackendService.cpp:5416:3
#21 0x5616d2039186 in
apache::thrift::TDispatchProcessor::process(std::shared_ptr<apache::thrift::protocol::TProtocol>,
std::shared_ptr<apache::thrift::protocol::TProtocol>, void*)
/home/zcp/repo_center/doris_branch-2.1/doris/thirdparty/installed/include/thrift/TDispatchProcessor.h:121:12
#22 0x5616faee19f7 in apache::thrift::server::TConnectedClient::run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x432699f7)
(BuildId: 09b7b6856fee4f7f)
#23 0x5616faee2cf6 in
apache::thrift::server::TThreadedServer::TConnectedClientRunner::run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326acf6)
(BuildId: 09b7b6856fee4f7f)
#24 0x5616faee830d in
apache::thrift::concurrency::Thread::threadMain(std::shared_ptr<apache::thrift::concurrency::Thread>)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4327030d)
(BuildId: 09b7b6856fee4f7f)
#25 0x5616faee81b3 in void std::__invoke_impl<void, void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>(std::__invoke_other, void
(*&&)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>&&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x432701b3)
(BuildId: 09b7b6856fee4f7f)
#26 0x5616faee8106 in std::__invoke_result<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>::type std::__invoke<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>(void
(*&&)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>&&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43270106)
(BuildId: 09b7b6856fee4f7f)
#27 0x5616faee8076 in void std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>::_M_invoke<0ul,
1ul>(std::_Index_tuple<0ul, 1ul>)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43270076)
(BuildId: 09b7b6856fee4f7f)
#28 0x5616faee7ffb in std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>::operator()()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326fffb)
(BuildId: 09b7b6856fee4f7f)
#29 0x5616faee7f9f in
std::thread::_State_impl<std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>>::_M_run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326ff9f)
(BuildId: 09b7b6856fee4f7f)
#30 0x5616fd80568f in execute_native_thread_routine
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:82:18
previously allocated by thread T3392 here:
#0 0x5616cea3853d in operator new(unsigned long)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x16dc053d)
(BuildId: 09b7b6856fee4f7f)
#1 0x5616fa5c3e29 in
std::_MakeUniq<doris::pipeline::PriorityTaskQueue>::__single_object
std::make_unique<doris::pipeline::PriorityTaskQueue>()
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/unique_ptr.h:962:30
#2 0x5616fa5c3e29 in
doris::pipeline::MultiCoreTaskQueue::MultiCoreTaskQueue(int)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_queue.cpp:139:39
#3 0x5616d19b276d in decltype(::new((void*)(0))
doris::pipeline::MultiCoreTaskQueue(std::declval<int&>()))
std::construct_at<doris::pipeline::MultiCoreTaskQueue,
int&>(doris::pipeline::MultiCoreTaskQueue*, int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/stl_construct.h:97:39
#4 0x5616d19b276d in void
std::allocator_traits<std::allocator<doris::pipeline::MultiCoreTaskQueue>>::construct<doris::pipeline::MultiCoreTaskQueue,
int&>(std::allocator<doris::pipeline::MultiCoreTaskQueue>&,
doris::pipeline::MultiCoreTaskQueue*, int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/alloc_traits.h:514:4
#5 0x5616d19b276d in
std::_Sp_counted_ptr_inplace<doris::pipeline::MultiCoreTaskQueue,
std::allocator<doris::pipeline::MultiCoreTaskQueue>,
(__gnu_cxx::_Lock_policy)2>::_Sp_counted_ptr_inplace<int&>(std::allocator<doris::pipeline::MultiCoreTaskQueue>,
int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:519:4
#6 0x5616d19b276d in
std::__shared_count<(__gnu_cxx::_Lock_policy)2>::__shared_count<doris::pipeline::MultiCoreTaskQueue,
std::allocator<doris::pipeline::MultiCoreTaskQueue>,
int&>(doris::pipeline::MultiCoreTaskQueue*&,
std::_Sp_alloc_shared_tag<std::allocator<doris::pipeline::MultiCoreTaskQueue>>,
int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:651:6
#7 0x5616d19b276d in
std::__shared_ptr<doris::pipeline::MultiCoreTaskQueue,
(__gnu_cxx::_Lock_policy)2>::__shared_ptr<std::allocator<doris::pipeline::MultiCoreTaskQueue>,
int&>(std::_Sp_alloc_shared_tag<std::allocator<doris::pipeline::MultiCoreTaskQueue>>,
int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr_base.h:1337:14
#8 0x5616d19b276d in
std::shared_ptr<doris::pipeline::MultiCoreTaskQueue>::shared_ptr<std::allocator<doris::pipeline::MultiCoreTaskQueue>,
int&>(std::_Sp_alloc_shared_tag<std::allocator<doris::pipeline::MultiCoreTaskQueue>>,
int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr.h:409:4
#9 0x5616d19b276d in
std::shared_ptr<doris::pipeline::MultiCoreTaskQueue>
std::allocate_shared<doris::pipeline::MultiCoreTaskQueue,
std::allocator<doris::pipeline::MultiCoreTaskQueue>,
int&>(std::allocator<doris::pipeline::MultiCoreTaskQueue> const&, int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr.h:860:14
#10 0x5616d19b276d in
std::shared_ptr<doris::pipeline::MultiCoreTaskQueue>
std::make_shared<doris::pipeline::MultiCoreTaskQueue, int&>(int&)
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/shared_ptr.h:876:14
#11 0x5616d19b276d in
doris::WorkloadGroup::upsert_thread_pool_no_lock(doris::WorkloadGroupInfo*,
std::shared_ptr<doris::CgroupCpuCtl>, doris::ExecEnv*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/runtime/workload_group/workload_group.cpp:462:27
#12 0x5616d19b5991 in
doris::WorkloadGroup::upsert_task_scheduler(doris::WorkloadGroupInfo*,
doris::ExecEnv*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/runtime/workload_group/workload_group.cpp:572:9
#13 0x5616d1a7ecd8 in
doris::WorkloadGroupListener::handle_topic_info(std::vector<doris::TopicInfo,
std::allocator<doris::TopicInfo>> const&)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/agent/workload_group_listener.cpp:60:13
#14 0x5616d1a7dd7e in
doris::TopicSubscriber::handle_topic_info(doris::TPublishTopicRequest const&)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/agent/topic_subscriber.cpp:45:35
#15 0x5616d2002932 in
doris::BackendServiceProcessor::process_publish_topic_info(int,
apache::thrift::protocol::TProtocol*, apache::thrift::protocol::TProtocol*,
void*)
/home/zcp/repo_center/doris_branch-2.1/doris/gensrc/build/gen_cpp/BackendService.cpp:6577:13
#16 0x5616d1fd6f11 in
doris::BackendServiceProcessor::dispatchCall(apache::thrift::protocol::TProtocol*,
apache::thrift::protocol::TProtocol*, std::__cxx11::basic_string<char,
std::char_traits<char>, std::allocator<char>> const&, int, void*)
/home/zcp/repo_center/doris_branch-2.1/doris/gensrc/build/gen_cpp/BackendService.cpp:5416:3
#17 0x5616d2039186 in
apache::thrift::TDispatchProcessor::process(std::shared_ptr<apache::thrift::protocol::TProtocol>,
std::shared_ptr<apache::thrift::protocol::TProtocol>, void*)
/home/zcp/repo_center/doris_branch-2.1/doris/thirdparty/installed/include/thrift/TDispatchProcessor.h:121:12
#18 0x5616faee19f7 in apache::thrift::server::TConnectedClient::run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x432699f7)
(BuildId: 09b7b6856fee4f7f)
#19 0x5616faee2cf6 in
apache::thrift::server::TThreadedServer::TConnectedClientRunner::run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326acf6)
(BuildId: 09b7b6856fee4f7f)
#20 0x5616faee830d in
apache::thrift::concurrency::Thread::threadMain(std::shared_ptr<apache::thrift::concurrency::Thread>)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4327030d)
(BuildId: 09b7b6856fee4f7f)
#21 0x5616faee81b3 in void std::__invoke_impl<void, void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>(std::__invoke_other, void
(*&&)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>&&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x432701b3)
(BuildId: 09b7b6856fee4f7f)
#22 0x5616faee8106 in std::__invoke_result<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>::type std::__invoke<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>(void
(*&&)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>&&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43270106)
(BuildId: 09b7b6856fee4f7f)
#23 0x5616faee8076 in void std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>::_M_invoke<0ul,
1ul>(std::_Index_tuple<0ul, 1ul>)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43270076)
(BuildId: 09b7b6856fee4f7f)
#24 0x5616faee7ffb in std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>::operator()()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326fffb)
(BuildId: 09b7b6856fee4f7f)
#25 0x5616faee7f9f in
std::thread::_State_impl<std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>>::_M_run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326ff9f)
(BuildId: 09b7b6856fee4f7f)
#26 0x5616fd80568f in execute_native_thread_routine
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:82:18
Thread T5188 (Pipe_test_follo) created by T3392 here:
#0 0x5616ce9e5caa in pthread_create
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x16d6dcaa)
(BuildId: 09b7b6856fee4f7f)
#1 0x5616d1df2cc9 in
doris::Thread::start_thread(std::__cxx11::basic_string<char,
std::char_traits<char>, std::allocator<char>> const&,
std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char>>
const&, std::function<void ()> const&, unsigned long,
scoped_refptr<doris::Thread>*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/thread.cpp:449:15
#2 0x5616d1e1d979 in doris::Status doris::Thread::create<void
(doris::ThreadPool::*)(), doris::ThreadPool*>(std::__cxx11::basic_string<char,
std::char_traits<char>, std::allocator<char>> const&,
std::__cxx11::basic_string<char, std::char_traits<char>, std::allocator<char>>
const&, void (doris::ThreadPool::* const&)(), doris::ThreadPool* const&,
scoped_refptr<doris::Thread>*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/thread.h:56:16
#3 0x5616d1e1423d in doris::ThreadPool::create_thread()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/threadpool.cpp:612:12
#4 0x5616d1e13e43 in doris::ThreadPool::init()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/threadpool.cpp:266:25
#5 0x5616cec31535 in doris::Status
doris::ThreadPoolBuilder::build<doris::ThreadPool>(std::unique_ptr<doris::ThreadPool,
std::default_delete<doris::ThreadPool>>*) const
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/threadpool.h:121:13
#6 0x5616fa5cef22 in doris::pipeline::TaskScheduler::start()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/pipeline/task_scheduler.cpp:208:5
#7 0x5616d19b2a9b in
doris::WorkloadGroup::upsert_thread_pool_no_lock(doris::WorkloadGroupInfo*,
std::shared_ptr<doris::CgroupCpuCtl>, doris::ExecEnv*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/runtime/workload_group/workload_group.cpp:467:47
#8 0x5616d19b5991 in
doris::WorkloadGroup::upsert_task_scheduler(doris::WorkloadGroupInfo*,
doris::ExecEnv*)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/runtime/workload_group/workload_group.cpp:572:9
#9 0x5616d1a7ecd8 in
doris::WorkloadGroupListener::handle_topic_info(std::vector<doris::TopicInfo,
std::allocator<doris::TopicInfo>> const&)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/agent/workload_group_listener.cpp:60:13
#10 0x5616d1a7dd7e in
doris::TopicSubscriber::handle_topic_info(doris::TPublishTopicRequest const&)
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/agent/topic_subscriber.cpp:45:35
#11 0x5616d2002932 in
doris::BackendServiceProcessor::process_publish_topic_info(int,
apache::thrift::protocol::TProtocol*, apache::thrift::protocol::TProtocol*,
void*)
/home/zcp/repo_center/doris_branch-2.1/doris/gensrc/build/gen_cpp/BackendService.cpp:6577:13
#12 0x5616d1fd6f11 in
doris::BackendServiceProcessor::dispatchCall(apache::thrift::protocol::TProtocol*,
apache::thrift::protocol::TProtocol*, std::__cxx11::basic_string<char,
std::char_traits<char>, std::allocator<char>> const&, int, void*)
/home/zcp/repo_center/doris_branch-2.1/doris/gensrc/build/gen_cpp/BackendService.cpp:5416:3
#13 0x5616d2039186 in
apache::thrift::TDispatchProcessor::process(std::shared_ptr<apache::thrift::protocol::TProtocol>,
std::shared_ptr<apache::thrift::protocol::TProtocol>, void*)
/home/zcp/repo_center/doris_branch-2.1/doris/thirdparty/installed/include/thrift/TDispatchProcessor.h:121:12
#14 0x5616faee19f7 in apache::thrift::server::TConnectedClient::run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x432699f7)
(BuildId: 09b7b6856fee4f7f)
#15 0x5616faee2cf6 in
apache::thrift::server::TThreadedServer::TConnectedClientRunner::run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326acf6)
(BuildId: 09b7b6856fee4f7f)
#16 0x5616faee830d in
apache::thrift::concurrency::Thread::threadMain(std::shared_ptr<apache::thrift::concurrency::Thread>)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4327030d)
(BuildId: 09b7b6856fee4f7f)
#17 0x5616faee81b3 in void std::__invoke_impl<void, void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>(std::__invoke_other, void
(*&&)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>&&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x432701b3)
(BuildId: 09b7b6856fee4f7f)
#18 0x5616faee8106 in std::__invoke_result<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>::type std::__invoke<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>(void
(*&&)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>&&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43270106)
(BuildId: 09b7b6856fee4f7f)
#19 0x5616faee8076 in void std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>::_M_invoke<0ul,
1ul>(std::_Index_tuple<0ul, 1ul>)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43270076)
(BuildId: 09b7b6856fee4f7f)
#20 0x5616faee7ffb in std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>::operator()()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326fffb)
(BuildId: 09b7b6856fee4f7f)
#21 0x5616faee7f9f in
std::thread::_State_impl<std::thread::_Invoker<std::tuple<void
(*)(std::shared_ptr<apache::thrift::concurrency::Thread>),
std::shared_ptr<apache::thrift::concurrency::Thread>>>>::_M_run()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326ff9f)
(BuildId: 09b7b6856fee4f7f)
#22 0x5616fd80568f in execute_native_thread_routine
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:82:18
Thread T3392 created by T933 here:
#0 0x5616ce9e5caa in pthread_create
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x16d6dcaa)
(BuildId: 09b7b6856fee4f7f)
#1 0x5616fd8057b5 in __gthread_create
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/x86_64-pc-linux-gnu/bits/gthr-default.h:663:35
#2 0x5616fd8057b5 in
std::thread::_M_start_thread(std::unique_ptr<std::thread::_State,
std::default_delete<std::thread::_State>>, void (*)())
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:147:37
#3 0x5616faee667c in apache::thrift::concurrency::Thread::start()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326e67c)
(BuildId: 09b7b6856fee4f7f)
#4 0x5616faee2a26 in
apache::thrift::server::TThreadedServer::onClientConnected(std::shared_ptr<apache::thrift::server::TConnectedClient>
const&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326aa26)
(BuildId: 09b7b6856fee4f7f)
#5 0x5616faedebc4 in
apache::thrift::server::TServerFramework::newlyConnectedClient(std::shared_ptr<apache::thrift::server::TConnectedClient>
const&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43266bc4)
(BuildId: 09b7b6856fee4f7f)
#6 0x5616faede25f in apache::thrift::server::TServerFramework::serve()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326625f)
(BuildId: 09b7b6856fee4f7f)
#7 0x5616faee2791 in apache::thrift::server::TThreadedServer::serve()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326a791)
(BuildId: 09b7b6856fee4f7f)
#8 0x5616d1e31419 in
doris::ThriftServer::ThriftServerEventProcessor::supervise()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/thrift_server.cpp:206:34
#9 0x5616fd80568f in execute_native_thread_routine
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:82:18
Thread T933 created by T0 here:
#0 0x5616ce9e5caa in pthread_create
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x16d6dcaa)
(BuildId: 09b7b6856fee4f7f)
#1 0x5616fd8057b5 in __gthread_create
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/x86_64-pc-linux-gnu/bits/gthr-default.h:663:35
#2 0x5616fd8057b5 in
std::thread::_M_start_thread(std::unique_ptr<std::thread::_State,
std::default_delete<std::thread::_State>>, void (*)())
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:147:37
#3 0x5616d1e37788 in doris::ThriftServer::start()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/thrift_server.cpp:421:5
#4 0x5616cea3f174 in main
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/service/doris_main.cpp:536:25
#5 0x7f83a4bcad8f in __libc_start_call_main
csu/../sysdeps/nptl/libc_start_call_main.h:58:16
Thread T2166 created by T933 here:
#0 0x5616ce9e5caa in pthread_create
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x16d6dcaa)
(BuildId: 09b7b6856fee4f7f)
#1 0x5616fd8057b5 in __gthread_create
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/include/x86_64-pc-linux-gnu/bits/gthr-default.h:663:35
#2 0x5616fd8057b5 in
std::thread::_M_start_thread(std::unique_ptr<std::thread::_State,
std::default_delete<std::thread::_State>>, void (*)())
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:147:37
#3 0x5616faee667c in apache::thrift::concurrency::Thread::start()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326e67c)
(BuildId: 09b7b6856fee4f7f)
#4 0x5616faee2a26 in
apache::thrift::server::TThreadedServer::onClientConnected(std::shared_ptr<apache::thrift::server::TConnectedClient>
const&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326aa26)
(BuildId: 09b7b6856fee4f7f)
#5 0x5616faedebc4 in
apache::thrift::server::TServerFramework::newlyConnectedClient(std::shared_ptr<apache::thrift::server::TConnectedClient>
const&)
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x43266bc4)
(BuildId: 09b7b6856fee4f7f)
#6 0x5616faede25f in apache::thrift::server::TServerFramework::serve()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326625f)
(BuildId: 09b7b6856fee4f7f)
#7 0x5616faee2791 in apache::thrift::server::TThreadedServer::serve()
(/mnt/hdd01/ci/doris-deploy-branch-2.1-local/be/lib/doris_be+0x4326a791)
(BuildId: 09b7b6856fee4f7f)
#8 0x5616d1e31419 in
doris::ThriftServer::ThriftServerEventProcessor::supervise()
/home/zcp/repo_center/doris_branch-2.1/doris/be/src/util/thrift_server.cpp:206:34
#9 0x5616fd80568f in execute_native_thread_routine
/data/gcc-11.1.0/build/x86_64-pc-linux-gnu/libstdc++-v3/src/c++11/../../../../../libstdc++-v3/src/c++11/thread.cc:82:18
SUMMARY: AddressSanitizer: heap-use-after-free
/var/local/ldb-toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/atomic_base.h:481:9
in std::__atomic_base<unsigned long>::load(std::memory_order) const
Shadow bytes around the buggy address:
0x61700518d180: fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd
0x61700518d200: fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd
0x61700518d280: fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd
0x61700518d300: fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd
0x61700518d380: fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd fd
=>0x61700518d400: fd fd fd fd fd fd fd fd[fd]fd fd fa fa fa fa fa
0x61700518d480: fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa
0x61700518d500: fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa
0x61700518d580: fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa
0x61700518d600: fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa
0x61700518d680: fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa fa
Shadow byte legend (one shadow byte represents 8 application bytes):
Addressable: 00
Partially addressable: 01 02 03 04 05 06 07
Heap left redzone: fa
Freed heap region: fd
Stack left redzone: f1
Stack mid redzone: f2
Stack right redzone: f3
Stack after return: f5
Stack use after scope: f8
Global redzone: f9
Global init order: f6
Poisoned by user: f7
Container overflow: fc
Array cookie: ac
Intra object redzone: bb
ASan internal: fe
Left alloca redzone: ca
Right alloca redzone: cb
==6632==ABORTING
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
