[Bug] When high concurrency, BE crash reports MissingRequiredFields in SendRpcResponse

[xinyiZzz]

Search before asking

• I had searched in the issues and found no similar issues.

Version

trunk

What's Wrong?

#0 MissingRequiredFields (this=0x0) at /root/doris-1.4.2-release/gensrc/build/gen_cpp/status.pb.cc:312
#1 doris::PStatus::IsInitialized (this=0x0) at /root/doris-1.4.2-release/gensrc/build/gen_cpp/status.pb.cc:312
#2 0x00000000022e6e5a in brpc::policy::SendRpcResponse(long, brpc::Controller*, google::protobuf::Message const*, google::protobuf::Message const*, brpc::Server const*, brpc::MethodStatus*, long) (correlation_id=72305774428210, cntl=
0x1208c240, req=0x422104b0, res=0x4ad5e54e0, server=Unhandled dwarf expression opcode 0xf3
) at ../src/brpc/policy/baidu_rpc_protocol.cpp:168
#3 0x00000000022e8656 in brpc::internal::FunctionClosure7<long, brpc::Controller*, google::protobuf::Message const*, google::protobuf::Message const*, brpc::Server const*, brpc::MethodStatus*, long>::Run() ()
at ../src/brpc/callback.h:483
#4 0x00000000015e082f in doris::DataStreamRecvr::SenderQueue::get_batch(doris::RowBatch**) (this=0xcfac3dc0, next_batch=Unhandled dwarf expression opcode 0xf3
) at ../src/runtime/data_stream_recvr.cc:187
#5 0x00000000015e0a2c in doris::DataStreamRecvr::get_batch (this=Unhandled dwarf expression opcode 0xf3
) at /opt/rh/devtoolset-10/root/usr/include/c++/10/bits/stl_vector.h:1043
#6 0x0000000001a88a16 in doris::ExchangeNode::fill_input_row_batch(doris::RuntimeState*) (this=0x36429c00, state=0xcbd21000) at /opt/rh/devtoolset-10/root/usr/include/c++/10/bits/shared_ptr_base.h:1324
#7 0x0000000001a89528 in doris::ExchangeNode::get_next(doris::RuntimeState*, doris::RowBatch*, bool*) (this=0x36429c00, state=0xcbd21000, output_batch=0x7fb09c1cd190, eos=0x7fb09c1cd13e) at ../src/exec/exchange_node.cpp:197
#8 0x0000000001a9165b in doris::HashJoinNode::construct_hash_table(doris::RuntimeState*) (this=0x1971ba700, state=0xcbd21000) at /opt/rh/devtoolset-10/root/usr/include/c++/10/bits/stl_vector.h:1043
#9 0x0000000001a91b82 in doris::HashJoinNode::build_side_thread(doris::RuntimeState*, std::promisedoris::Status*) (this=Unhandled dwarf expression opcode 0xf3
) at ../src/exec/hash_join_node.cpp:183
#10 0x00000000039ce260 in execute_native_thread_routine ()
#11 0x000000318b207851 in start_thread () from /lib64/libpthread.so.0
#12 0x000000318aee767d in clone () from /lib64/libc.so.6

What You Expected?

On the SSB test set with a total data volume of 46G, stress test the following SQL:

SELECT d_year, s_city, p_brand, SUM(lo_revenue - lo_supplycost) AS PROFIT FROM date, customer, supplier, part, lineorder WHERE lo_custkey = c_custkey AND lo_suppkey = s_suppkey AND lo_partkey = p_partkey AND lo_orderdate = d_datekey AND s_nation = 'UNITED STATES' AND (d_year = 1997 OR d_year = 1998) AND p_category = 'MFGR#14' GROUP BY d_year, s_city, p_brand ORDER BY d_year, s_city, p_brand

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