[Bug] 使用insert-values语句导致be节点挂了 #12760
Description
Search before asking
- I had searched in the issues and found no similar issues.
Version
doris-1.1.0-rc05
What's Wrong?
使用insert-values语句导致be节点挂了
INSERT into ads_target_result(t_id,`query`,date,create_time,t_code,reserved_column1)
values(
'1571083647592755202',cast(if(110.0 is null & 110.0=0,0,110.0/110.0) as string),'2022-08-01',now(),'ZB00027','8'
)
其中值cast(if(110.0 is null & 110.0=0,0,110.0/110.0) as string)导致be节点挂了，使用select语句查这条数据不会有问题，
使用insert select也不会挂，综合现象是在insert value中使用了稍微复杂的计算
以下是be.out日志
`
*** Check failure stack trace: ***
@ 0x55cd1b5359ed google::LogMessage::Fail()
@ 0x55cd1b537f29 google::LogMessage::SendToLog()
@ 0x55cd1b535556 google::LogMessage::Flush()
@ 0x55cd1b538599 google::LogMessageFatal::~LogMessageFatal()
@ 0x55cd1aa9fb7d (unknown)
@ 0x55cd1aa9fc59 doris::vectorized::create_block_with_nested_columns()
@ 0x55cd1ab34da0 _ZZNK5doris10vectorized12FunctionCast23prepare_remove_nullableERKSt10shared_ptrIKNS0_9IDataTypeEES7_bENKUlPN9doris_udf15FunctionContextERNS0_5BlockERKSt6vectorImSaImEEmmE_clESA_SC_SH_mm
@ 0x55cd1ab35d4e ZNSt17_Function_handlerIFN5doris6StatusEPN9doris_udf15FunctionContextERNS0_10vectorized5BlockERKSt6vectorImSaImEEmmEZNKS5_12FunctionCast23prepare_remove_nullableERKSt10shared_ptrIKNS5_9IDataTypeEESK_bEUlS4_S7_SC_mmE_E9_M_invokeERKSt9_Any_dataOS4_S7_SC_OmSR
@ 0x55cd1ab31599 doris::vectorized::PreparedFunctionCast::execute_impl()
@ 0x55cd1aa9d725 doris::vectorized::PreparedFunctionImpl::execute_without_low_cardinality_columns()
@ 0x55cd1aa9e3d5 doris::vectorized::PreparedFunctionImpl::default_implementation_for_constant_arguments()
@ 0x55cd1aa9ecbb doris::vectorized::PreparedFunctionImpl::execute()
@ 0x55cd1a46cf91 doris::vectorized::VCastExpr::execute()
@ 0x55cd19e8a777 doris::vectorized::VExprContext::execute()
@ 0x55cd1a184c10 doris::vectorized::VUnionNode::get_next_const()
@ 0x55cd1a186028 doris::vectorized::VUnionNode::get_next()
@ 0x55cd198947fa doris::PlanFragmentExecutor::get_vectorized_internal()
@ 0x55cd19898d7d doris::PlanFragmentExecutor::open_vectorized_internal()
@ 0x55cd1989a82f doris::PlanFragmentExecutor::open()
@ 0x55cd198141c5 doris::FragmentExecState::execute()
@ 0x55cd19818e7a doris::FragmentMgr::_exec_actual()
@ 0x55cd1982241c std::_Function_handler<>::_M_invoke()
@ 0x55cd199c5ca9 doris::ThreadPool::dispatch_thread()
@ 0x55cd199bf29f doris::Thread::supervise_thread()
@ 0x7efed3197ea5 start_thread
@ 0x7efed34aab0d __clone
@ (nil) (unknown)
*** Aborted at 1663639950 (unix time) try "date -d @1663639950" if you are using GNU date ***
*** SIGABRT unkown detail explain (@0x549c) received by PID 21660 (TID 0x7efe88d6d700) from PID 21660; stack trace: ***
0# 0x000055CD19429098 in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
1# 0x00007EFED33E2400 in /lib64/libc.so.6
2# gsignal in /lib64/libc.so.6
3# abort in /lib64/libc.so.6
4# 0x000055CD19100576 in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
5# 0x000055CD1B5359ED in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
6# google::LogMessage::SendToLog() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
7# google::LogMessage::Flush() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
8# google::LogMessageFatal::~LogMessageFatal() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
9# 0x000055CD1AA9FB7D in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
10# doris::vectorized::create_block_with_nested_columns(doris::vectorized::Block const&, std::vector<unsigned long, std::allocator > const&) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
11# doris::vectorized::FunctionCast::prepare_remove_nullable(std::shared_ptr<doris::vectorized::IDataType const> const&, std::shared_ptr<doris::vectorized::IDataType const> const&, bool) const::{lambda(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long)#1}::operator()(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long) const in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
12# std::_Function_handler<doris::Status (doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long), doris::vectorized::FunctionCast::prepare_remove_nullable(std::shared_ptr<doris::vectorized::IDataType const> const&, std::shared_ptr<doris::vectorized::IDataType const> const&, bool) const::{lambda(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long)#1}>::_M_invoke(std::_Any_data const&, doris_udf::FunctionContext*&&, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long&&, unsigned long&&) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
13# doris::vectorized::PreparedFunctionCast::execute_impl(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
14# doris::vectorized::PreparedFunctionImpl::execute_without_low_cardinality_columns(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long, bool) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
15# doris::vectorized::PreparedFunctionImpl::default_implementation_for_constant_arguments(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long, bool, bool*) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
16# doris::vectorized::PreparedFunctionImpl::execute(doris_udf::FunctionContext*, doris::vectorized::Block&, std::vector<unsigned long, std::allocator > const&, unsigned long, unsigned long, bool) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
17# doris::vectorized::VCastExpr::execute(doris::vectorized::VExprContext*, doris::vectorized::Block*, int*) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
18# doris::vectorized::VExprContext::execute(doris::vectorized::Block*, int*) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
19# doris::vectorized::VUnionNode::get_next_const(doris::RuntimeState*, doris::vectorized::Block*) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
20# doris::vectorized::VUnionNode::get_next(doris::RuntimeState*, doris::vectorized::Block*, bool*) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
21# doris::PlanFragmentExecutor::get_vectorized_internal(doris::vectorized::Block**) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
22# doris::PlanFragmentExecutor::open_vectorized_internal() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
23# doris::PlanFragmentExecutor::open() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
24# doris::FragmentExecState::execute() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
25# doris::FragmentMgr::_exec_actual(std::shared_ptrdoris::FragmentExecState, std::function<void (doris::PlanFragmentExecutor*)>) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
26# std::_Function_handler<void (), std::_Bind_result<void, void (doris::FragmentMgr::(doris::FragmentMgr, std::shared_ptrdoris::FragmentExecState, std::function<void (doris::PlanFragmentExecutor*)>))(std::shared_ptrdoris::FragmentExecState, std::function<void (doris::PlanFragmentExecutor*)>)> >::_M_invoke(std::_Any_data const&) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
27# doris::ThreadPool::dispatch_thread() in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
28# doris::Thread::supervise_thread(void*) in /opt/service/apache-doris-1.1.0-bin-x86-jdk8/be/lib/doris_be
29# start_thread in /lib64/libpthread.so.0
30# clone in /lib64/libc.so.6
以下是be.WARNING日志
F0920 10:12:30.056149 21874 function_helpers.cpp:53] Illegal column for DataTypeNullable
后续发现是&字符导致
What You Expected?
怎样才能不要直接让be节点挂
How to Reproduce?
No response
Anything Else?
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct