zhangstar333 opened a new pull request, #38706:
URL: https://github.com/apache/doris/pull/38706
## Proposed changes
when build hashtable in set operator, it's should check all
build_not_ignore_null instead of always use build_not_ignore_null[0]. this
will create hashtable which is has_null = false;
but maybe have nullable after 0 child, so can't handle nullable column in
hashtable.
```
8# google::LogMessageFatal::~LogMessageFatal() in
/mnt/disk2/zhangsida/doris/output/be/lib/doris_be
9# doris::vectorized::IColumn::get_raw_data() const in
/mnt/disk2/zhangsida/doris/output/be/lib/doris_be
10# void
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>::pack_fixeds<wide::integer<128ul, unsigned int> >(unsigned long,
std::vector<doris::vectorized::IColumn const*,
std::allocator<doris::vectorized::IColumn const*> > const&,
std::vector<doris::vectorized::IColumn const*,
std::allocator<doris::vectorized::IColumn const*> > const&,
std::vector<wide::integer<128ul, unsigned int>,
std::allocator<wide::integer<128ul, unsigned int> > >&) at
/mnt/disk2/zhangsida/doris/be/src/vec/common/hash_table/hash_map_context.h:405
11#
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>::init_serialized_keys(std::vector<doris::vectorized::IColumn const*,
std::allocator<doris::vectorized::IColumn const*> > const&, unsigned long,
unsigned char const*, bool, bool, unsigned int) at
/mnt/disk2/zhangsida/doris/be/src/vec/common/hash_table/hash_map_context.h:473
12#
doris::vectorized::HashTableBuild<doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>,
true>::operator()(doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>&, doris::vectorized::Arena&) at
/mnt/disk2/zhangsida/doris/be/src/vec/common/hash_table/hash_table_set_build.h:34
13# auto
doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&,
doris::RuntimeState*)::{lambda(auto:1&&)#1}::operator()<doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>&>(doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>&) const at /mnt/disk2/zhan
gsida/doris/be/src/pipeline/exec/set_sink_operator.cpp:97
"be.out" 5931L, 1478192C
5885,1 99%
14# void std::__invoke_impl<void,
doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1},
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>&>(std::__invoke_other,
doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1}&&,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wid
e::integer<128ul, unsigned int> >, HashTableNoState>,
HashCRC32<wide::integer<128ul, unsigned int> >, HashTableGrower<10ul>,
Allocator<true, true, false, DefaultMemoryAllocator> >, false>&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:61
15#
std::__invoke_result<doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1},
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>&>::type
std::__invoke<doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1},
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<1
28ul, unsigned int> >, HashTableNoState>, HashCRC32<wide::integer<128ul,
unsigned int> >, HashTableGrower<10ul>, Allocator<true, true, false,
DefaultMemoryAllocator> >,
false>&>(doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1}&&,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:96
16#
_ZNSt8__detail9__variant17__gen_vtable_implINS0_12_Multi_arrayIPFNS0_21__deduce_visit_resultIvEEOZN5doris8pipeline16SetSinkOperatorXILb1EE20_process_build_blockERNS6_17SetSinkLocalStateILb1EEERNS5_10vectorized5BlockEPNS5_12RuntimeStateEEUlOT_E_RSt7variantIJSt9monostateNSC_16MethodSerializedINS5_12HashMapTableINS5_9StringRefENS5_11HashMapCellISP_NS6_19RowRefListWithFlagsE11DefaultHashISP_vE16HashTableNoStateEEST_15HashTableGrowerILm10EE9AllocatorILb1ELb1ELb0E22DefaultMemoryAllocatorEEEEENSC_15MethodOneNumberIhNSO_IhNSQ_IhSR_9HashCRC32IhESU_EES15_SX_S10_EEEENS13_ItNSO_ItNSQ_ItSR_S14_ItESU_EES19_SX_S10_EEEENS13_IjNSO_IjNSQ_IjSR_S14_IjESU_EES1D_SX_S10_EEEENS13_ImNSO_ImNSQ_ImSR_S14_ImESU_EES1H_SX_S10_EEEENS13_IN4wide7integerILm128EjEENSO_IS1N_NSQ_IS1N_SR_S14_IS1N_ESU_EES1O_SX_S10_EEEENS13_INS1M_ILm256EjEENSO_IS1S_NSQ_IS1S_SR_S14_IS1S_ESU_EES1T_SX_S10_EEEENSC_15MethodKeysFixedIS1J_Lb1EEENS1X_IS1J_Lb0EEENS1X_IS1Q_Lb1EEENS1X_IS1Q_Lb0EEENS1X_IS1V_Lb1EEENS1X_IS1V_Lb0EEENS1X_INSO_INSC_7U
Int136ENSQ_IS24_SR_S14_IS24_ESU_EES25_SX_S10_EELb1EEENS1X_IS27_Lb0EEEEEEJEEESt16integer_sequenceImJLm11EEEE14__visit_invokeESK_S2B_
at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/variant:1013
17#
_ZSt10__do_visitINSt8__detail9__variant21__deduce_visit_resultIvEEZN5doris8pipeline16SetSinkOperatorXILb1EE20_process_build_blockERNS5_17SetSinkLocalStateILb1EEERNS4_10vectorized5BlockEPNS4_12RuntimeStateEEUlOT_E_JRSt7variantIJSt9monostateNSB_16MethodSerializedINS4_12HashMapTableINS4_9StringRefENS4_11HashMapCellISN_NS5_19RowRefListWithFlagsE11DefaultHashISN_vE16HashTableNoStateEESR_15HashTableGrowerILm10EE9AllocatorILb1ELb1ELb0E22DefaultMemoryAllocatorEEEEENSB_15MethodOneNumberIhNSM_IhNSO_IhSP_9HashCRC32IhESS_EES13_SV_SY_EEEENS11_ItNSM_ItNSO_ItSP_S12_ItESS_EES17_SV_SY_EEEENS11_IjNSM_IjNSO_IjSP_S12_IjESS_EES1B_SV_SY_EEEENS11_ImNSM_ImNSO_ImSP_S12_ImESS_EES1F_SV_SY_EEEENS11_IN4wide7integerILm128EjEENSM_IS1L_NSO_IS1L_SP_S12_IS1L_ESS_EES1M_SV_SY_EEEENS11_INS1K_ILm256EjEENSM_IS1Q_NSO_IS1Q_SP_S12_IS1Q_ESS_EES1R_SV_SY_EEEENSB_15MethodKeysFixedIS1H_Lb1EEENS1V_IS1H_Lb0EEENS1V_IS1O_Lb1EEENS1V_IS1O_Lb0EEENS1V_IS1T_Lb1EEENS1V_IS1T_Lb0EEENS1V_INSM_INSB_7UInt136ENSO_IS22_SP_S12_IS22_ESS_EES2
3_SV_SY_EELb1EEENS1V_IS25_Lb0EEEEEEEDcOT0_DpOT1_ at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/variant:1714
@@@
5892,1 99%
18# decltype(auto)
std::visit<doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1},
std::variant<std::monostate,
doris::vectorized::MethodSerialized<doris::HashMapTable<doris::StringRef,
doris::HashMapCell<doris::StringRef, doris::pipeline::RowRefListWithFlags,
DefaultHash<doris::StringRef, void>, HashTableNoState>,
DefaultHash<doris::StringRef, void>, HashTableGrower<10ul>, Allocator<true,
true, false, DefaultMemoryAllocator> > >,
doris::vectorized::MethodOneNumber<unsigned char, doris::HashMapTable<unsigned
char, doris::HashMapCell<unsigned char, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned char>, HashTableNoState>, HashCRC32<unsigned char>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodOneNumber<unsigned short,
doris::HashMapTable<unsigned short, doris::HashMapCell<unsigned short, doris
::pipeline::RowRefListWithFlags, HashCRC32<unsigned short>, HashTableNoState>,
HashCRC32<unsigned short>, HashTableGrower<10ul>, Allocator<true, true, false,
DefaultMemoryAllocator> > >, doris::vectorized::MethodOneNumber<unsigned int,
doris::HashMapTable<unsigned int, doris::HashMapCell<unsigned int,
doris::pipeline::RowRefListWithFlags, HashCRC32<unsigned int>,
HashTableNoState>, HashCRC32<unsigned int>, HashTableGrower<10ul>,
Allocator<true, true, false, DefaultMemoryAllocator> > >,
doris::vectorized::MethodOneNumber<unsigned long, doris::HashMapTable<unsigned
long, doris::HashMapCell<unsigned long, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned long>, HashTableNoState>, HashCRC32<unsigned long>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodOneNumber<wide::integer<128ul, unsigned int>,
doris::HashMapTable<wide::integer<128ul, unsigned int>,
doris::HashMapCell<wide::integer<128ul, unsigned int>, doris::pipeline
::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodOneNumber<wide::integer<256ul, unsigned int>,
doris::HashMapTable<wide::integer<256ul, unsigned int>,
doris::HashMapCell<wide::integer<256ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<256ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<256ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodKeysFixed<doris::HashMapTable<unsigned long,
doris::HashMapCell<unsigned long, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned long>, HashTableNoState>, HashCRC32<unsigned long>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
true>, doris::vectorized::MethodKeysFixed<doris::HashMapTable<unsigned
long, doris::HashMapCell<unsigned long, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned long>, HashTableNoState>, HashCRC32<unsigned long>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
true>,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator>
>, false>,
>doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<256ul,
>unsigned int>, doris::HashMapCell<wide::integer<256ul, unsigned int>,
>doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<256ul, unsigned
>int> >, HashTableNoState>, HashCRC32<wide::integer<256ul, unsigned int> >,
>HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator>
>>, true>,
>doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<256ul,
>unsigned int>, doris::HashMapCell<wide::integer<256ul, unsigned int>,
>doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<256ul, unsigned
>int> >, HashTableNoState>, HashCRC32<wide::integer<256ul, unsigned int> >,
>HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator>
>>, false>,
>doris::vectorized::MethodKeysFixed<doris::HashMapTable<doris::vectorized::UInt136,
> doris::HashMapCell<doris::vectorized::UInt136,
>doris::pipeline::RowRefListWithFlags, HashCRC32<doris::vectorized::UInt136>,
>HashTabl
eNoState>, HashCRC32<doris::vectorized::UInt136>, HashTableGrower<10ul>,
Allocator<true, true, false, DefaultMemoryAllocator> >, true>,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<doris::vectorized::UInt136,
doris::HashMapCell<doris::vectorized::UInt136,
doris::pipeline::RowRefListWithFlags, HashCRC32<doris::vectorized::UInt136>,
HashTableNoState>, HashCRC32<doris::vectorized::UInt136>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>
>&>(doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1}&&,
std::variant<std::monostate,
doris::vectorized::MethodSerialized<doris::HashMapTable<doris::StringRef,
doris::HashMapCell<doris::StringRef, doris::pipeline::RowRefListWithFlags,
DefaultHash<doris::StringRef, void>, HashTableNoState>,
DefaultHash<doris::StringRef, void>, HashTableGrower<10ul>, Allocator<true, tru
5893,1 99%
19#
doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/exec/set_sink_operator.cpp:91
20# doris::pipeline::SetSinkOperatorX<true>::sink(doris::RuntimeState*,
doris::vectorized::Block*, bool) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/exec/set_sink_operator.cpp:52
21# doris::pipeline::PipelineTask::execute(bool*)::$_1::operator()() const
at /mnt/disk2/zhangsida/doris/be/src/pipeline/pipeline_task.cpp:362
22# doris::pipeline::PipelineTask::execute(bool*) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/pipeline_task.cpp:365
23# doris::pipeline::TaskScheduler::_do_work(unsigned long) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/task_scheduler.cpp:138
24# doris::pipeline::TaskScheduler::start()::$_0::operator()() const at
/mnt/disk2/zhangsida/doris/be/src/pipeline/task_scheduler.cpp:64
25# void std::__invoke_impl<void,
doris::pipeline::TaskScheduler::start()::$_0&>(std::__invoke_other,
doris::pipeline::TaskScheduler::start()::$_0&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:61
26# std::enable_if<is_invocable_r_v<void,
doris::pipeline::TaskScheduler::start()::$_0&>, void>::type
std::__invoke_r<void,
doris::pipeline::TaskScheduler::start()::$_0&>(doris::pipeline::TaskScheduler::start()::$_0&)
at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:117
27# std::_Function_handler<void (),
doris::pipeline::TaskScheduler::start()::$_0>::_M_invoke(std::_Any_data const&)
at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:291
28# std::function<void ()>::operator()() const at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:560
29# doris::FunctionRunnable::run() at
/mnt/disk2/zhangsida/doris/be/src/util/threadpool.cpp:48
30# doris::ThreadPool::dispatch_thread() at
/mnt/disk2/zhangsida/doris/be/src/util/threadpool.cpp:543
31# void std::__invoke_impl<void, void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>(std::__invoke_memfun_deref, void
(doris::ThreadPool::*&)(), doris::ThreadPool*&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:74
32# std::__invoke_result<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>::type std::__invoke<void (doris::ThreadPool::*&)(),
doris::ThreadPool*&>(void (doris::ThreadPool::*&)(), doris::ThreadPool*&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:96
33# void std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()>::__call<void, ,
0ul>(std::tuple<>&&, std::_Index_tuple<0ul>) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/functional:420
34# void std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()>::operator()<, void>() at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/functional:503
35# void std::__invoke_impl<void, std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()>&>(std::__invoke_other,
std::_Bind<void (doris::ThreadPool::*(doris::ThreadPool*))()>&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:61
36# std::enable_if<is_invocable_r_v<void, std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()>&>, void>::type
std::__invoke_r<void, std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()>&>(std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()>&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:117
37# std::_Function_handler<void (), std::_Bind<void
(doris::ThreadPool::*(doris::ThreadPool*))()> >::_M_invoke(std::_Any_data
const&) at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:291
38# std::function<void ()>::operator()() const at
/mnt/disk2/zhangsida/install_data/ldb_toolchain/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:560
39# doris::Thread::supervise_thread(void*) at
/mnt/disk2/zhangsida/doris/be/src/util/thread.cpp:498
5894,1 99%
18# decltype(auto)
std::visit<doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1},
std::variant<std::monostate,
doris::vectorized::MethodSerialized<doris::HashMapTable<doris::StringRef,
doris::HashMapCell<doris::StringRef, doris::pipeline::RowRefListWithFlags,
DefaultHash<doris::StringRef, void>, HashTableNoState>,
DefaultHash<doris::StringRef, void>, HashTableGrower<10ul>, Allocator<true,
true, false, DefaultMemoryAllocator> > >,
doris::vectorized::MethodOneNumber<unsigned char, doris::HashMapTable<unsigned
char, doris::HashMapCell<unsigned char, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned char>, HashTableNoState>, HashCRC32<unsigned char>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodOneNumber<unsigned short,
doris::HashMapTable<unsigned short, doris::HashMapCell<unsigned short, doris
::pipeline::RowRefListWithFlags, HashCRC32<unsigned short>, HashTableNoState>,
HashCRC32<unsigned short>, HashTableGrower<10ul>, Allocator<true, true, false,
DefaultMemoryAllocator> > >, doris::vectorized::MethodOneNumber<unsigned int,
doris::HashMapTable<unsigned int, doris::HashMapCell<unsigned int,
doris::pipeline::RowRefListWithFlags, HashCRC32<unsigned int>,
HashTableNoState>, HashCRC32<unsigned int>, HashTableGrower<10ul>,
Allocator<true, true, false, DefaultMemoryAllocator> > >,
doris::vectorized::MethodOneNumber<unsigned long, doris::HashMapTable<unsigned
long, doris::HashMapCell<unsigned long, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned long>, HashTableNoState>, HashCRC32<unsigned long>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodOneNumber<wide::integer<128ul, unsigned int>,
doris::HashMapTable<wide::integer<128ul, unsigned int>,
doris::HashMapCell<wide::integer<128ul, unsigned int>, doris::pipeline
::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodOneNumber<wide::integer<256ul, unsigned int>,
doris::HashMapTable<wide::integer<256ul, unsigned int>,
doris::HashMapCell<wide::integer<256ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<256ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<256ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >
>, doris::vectorized::MethodKeysFixed<doris::HashMapTable<unsigned long,
doris::HashMapCell<unsigned long, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned long>, HashTableNoState>, HashCRC32<unsigned long>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
true>, doris::vectorized::MethodKeysFixed<doris::HashMapTable<unsigned
long, doris::HashMapCell<unsigned long, doris::pipeline::RowRefListWithFlags,
HashCRC32<unsigned long>, HashTableNoState>, HashCRC32<unsigned long>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
true>,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<128ul,
unsigned int>, doris::HashMapCell<wide::integer<128ul, unsigned int>,
doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<128ul, unsigned
int> >, HashTableNoState>, HashCRC32<wide::integer<128ul, unsigned int> >,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator>
>, false>,
>doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<256ul,
>unsigned int>, doris::HashMapCell<wide::integer<256ul, unsigned int>,
>doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<256ul, unsigned
>int> >, HashTableNoState>, HashCRC32<wide::integer<256ul, unsigned int> >,
>HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator>
>>, true>,
>doris::vectorized::MethodKeysFixed<doris::HashMapTable<wide::integer<256ul,
>unsigned int>, doris::HashMapCell<wide::integer<256ul, unsigned int>,
>doris::pipeline::RowRefListWithFlags, HashCRC32<wide::integer<256ul, unsigned
>int> >, HashTableNoState>, HashCRC32<wide::integer<256ul, unsigned int> >,
>HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator>
>>, false>,
>doris::vectorized::MethodKeysFixed<doris::HashMapTable<doris::vectorized::UInt136,
> doris::HashMapCell<doris::vectorized::UInt136,
>doris::pipeline::RowRefListWithFlags, HashCRC32<doris::vectorized::UInt136>,
>HashTabl
eNoState>, HashCRC32<doris::vectorized::UInt136>, HashTableGrower<10ul>,
Allocator<true, true, false, DefaultMemoryAllocator> >, true>,
doris::vectorized::MethodKeysFixed<doris::HashMapTable<doris::vectorized::UInt136,
doris::HashMapCell<doris::vectorized::UInt136,
doris::pipeline::RowRefListWithFlags, HashCRC32<doris::vectorized::UInt136>,
HashTableNoState>, HashCRC32<doris::vectorized::UInt136>,
HashTableGrower<10ul>, Allocator<true, true, false, DefaultMemoryAllocator> >,
false>
>&>(doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*)::{lambda(auto:1&&)#1}&&,
std::variant<std::monostate,
doris::vectorized::MethodSerialized<doris::HashMapTable<doris::StringRef,
doris::HashMapCell<doris::StringRef, doris::pipeline::RowRefListWithFlags,
DefaultHash<doris::StringRef, void>, HashTableNoState>,
DefaultHash<doris::StringRef, void>, HashTableGrower<10ul>, Allocator<true, tru
5893,1 99%
19#
doris::pipeline::SetSinkOperatorX<true>::_process_build_block(doris::pipeline::SetSinkLocalState<true>&,
doris::vectorized::Block&, doris::RuntimeState*) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/exec/set_sink_operator.cpp:91
20# doris::pipeline::SetSinkOperatorX<true>::sink(doris::RuntimeState*,
doris::vectorized::Block*, bool) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/exec/set_sink_operator.cpp:52
21# doris::pipeline::PipelineTask::execute(bool*)::$_1::operator()() const
at /mnt/disk2/zhangsida/doris/be/src/pipeline/pipeline_task.cpp:362
22# doris::pipeline::PipelineTask::execute(bool*) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/pipeline_task.cpp:365
23# doris::pipeline::TaskScheduler::_do_work(unsigned long) at
/mnt/disk2/zhangsida/doris/be/src/pipeline/task_scheduler.cpp:138
24# doris::pipeline::TaskScheduler::start()::$_0::operator()() const at
/mnt/disk2/zhangsida/doris/be/src/pipeline/task_scheduler.cpp:64
```
<!--Describe your changes.-->
--
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
