xy720 opened a new pull request, #58038:
URL: https://github.com/apache/doris/pull/58038
### What problem does this PR solve?
Issue Number: close #58037
Problem Summary:
```
#0 0x00007f9aca4a3f8c in __pthread_kill_implementation () from
/lib64/libc.so.6
#1 0x00007f9aca454a26 in raise () from /lib64/libc.so.6
#2 0x00007f9aca43d87c in abort () from /lib64/libc.so.6
#3 0x0000561dc3d1ea1d in ?? ()
#4 0x0000561dc3d1105a in google::LogMessage::Fail() ()
#5 0x0000561dc3d14146 in google::LogMessage::SendToLog() ()
#6 0x0000561dc3d10b90 in google::LogMessage::Flush() ()
#7 0x0000561dc3d14989 in google::LogMessageFatal::~LogMessageFatal() ()
#8 0x0000561db854c996 in assert_cast<doris::vectorized::ColumnStr<unsigned
int> const&, (TypeCheckOnRelease)1, doris::vectorized::IColumn
const&>(doris::vectorized::IColumn
const&)::{lambda(auto:1&&)#1}::operator()<doris::vectorized::IColumn
const&>(doris::vectorized::IColumn const&) const
(this=this@entry=0x7f9658ccc1f8, from=...) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/common/assert_cast.h:58
#9 0x0000561db854c7d7 in assert_cast<doris::vectorized::ColumnStr<unsigned
int> const&, (TypeCheckOnRelease)1, doris::vectorized::IColumn const&>
(from=...) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/common/assert_cast.h:73
#10 0x0000561db854bb0b in doris::vectorized::ColumnStr<unsigned
int>::compare_at (this=0x7f957a14e2c0, n=1159288, m=6, rhs_=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/columns/column_string.h:526
#11 0x0000561dbe108c6b in
doris::vectorized::GenericComparisonImpl<doris::vectorized::EqualsOp<int, int>
>::vector_constant (a=..., b=..., c=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/functions_comparison.h:112
#12 doris::vectorized::FunctionComparison<doris::vectorized::EqualsOp,
doris::vectorized::NameEquals>::execute_generic_identical_types (
this=<optimized out>, block=..., result=result@entry=10,
c0=0x7f957a14e2c0, c1=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/functions_comparison.h:506
#13 0x0000561dbdf9e97e in
doris::vectorized::FunctionComparison<doris::vectorized::EqualsOp,
doris::vectorized::NameEquals>::execute_generic (
this=0x7f96d6fb1b90, block=..., result=10, c0=..., c1=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/functions_comparison.h:517
#14 doris::vectorized::FunctionComparison<doris::vectorized::EqualsOp,
doris::vectorized::NameEquals>::execute_impl (this=0x7f96d6fb1b90,
context=<optimized out>, block=..., arguments=..., result=10,
input_rows_count=104)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/functions_comparison.h:707
#15 0x0000561dbdcf1b8f in doris::vectorized::DefaultExecutable::execute_impl
(this=<optimized out>, context=0x6, block=..., arguments=...,
result=1, input_rows_count=104) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.h:472
#16 0x0000561dbeea76ae in
doris::vectorized::PreparedFunctionImpl::_execute_skipped_constant_deal
(this=this@entry=0x7f99f62a65d0,
context=context@entry=0x7f99f6442b00, block=..., args=...,
result=result@entry=10, input_rows_count=104, dry_run=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.cpp:121
#17 0x0000561dbeea4ce8 in
doris::vectorized::PreparedFunctionImpl::execute_without_low_cardinality_columns
(this=0x7f99f62a65d0,
context=0x7f99f6442b00, block=..., args=..., result=10,
input_rows_count=104, dry_run=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.cpp:246
#18
doris::vectorized::PreparedFunctionImpl::default_implementation_for_nulls
(this=this@entry=0x7f99f62a65d0,
context=context@entry=0x7f99f6442b00, block=..., args=...,
result=result@entry=10, input_rows_count=104, dry_run=<optimized out>,
executed=0x7f9658ccc666) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.cpp:218
#19 0x0000561dbeea4e9c in
doris::vectorized::PreparedFunctionImpl::_execute_skipped_constant_deal
(this=0x7f99f62a65d0, context=0x7f99f6442b00,
block=..., args=..., result=10, input_rows_count=<optimized out>,
dry_run=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.cpp:112
#20
doris::vectorized::PreparedFunctionImpl::execute_without_low_cardinality_columns
(this=0x7f99f62a65d0, context=0x7f99f6442b00, block=...,
args=..., result=10, input_rows_count=104, dry_run=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.cpp:246
#21 0x0000561dbeea4f66 in doris::vectorized::PreparedFunctionImpl::execute
(this=0x11b078, context=0x6, block=..., args=..., result=1,
input_rows_count=104, dry_run=<optimized out>) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.cpp:252
#22 0x0000561dbdcf1500 in doris::vectorized::IFunctionBase::execute
(this=<optimized out>, context=0x7f99f6442b00, block=..., arguments=...,
result=10, input_rows_count=104, dry_run=<optimized out>) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/functions/function.h:195
--Type <RET> for more, q to quit, c to continue without paging--c
#23 0x0000561dbdceccad in doris::vectorized::VectorizedFnCall::_do_execute
(this=0x7f96f0fec510, context=0x7f957f09cdf0, block=0x7f957b02a3b0,
result_column_id=0x7f9658ccca14, args=...) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exprs/vectorized_fn_call.cpp:197
#24 0x0000561dbdced2c6 in doris::vectorized::VectorizedFnCall::execute
(this=0x11b078, context=0x6,
block=0x7f9aca4a3f8c <__pthread_kill_implementation+268>,
result_column_id=0x7f9658ccbe10)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exprs/vectorized_fn_call.cpp:212
#25 0x0000561dbdd1e51b in doris::vectorized::VExprContext::execute
(this=0x7f957f09cdf0,
block=0x7f9aca4a3f8c <__pthread_kill_implementation+268>,
block@entry=0x7f957b02a3b0,
result_column_id=result_column_id@entry=0x7f9658ccca14)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exprs/vexpr_context.cpp:55
#26 0x0000561dbdd1fcb5 in doris::vectorized::VExprContext::execute_conjuncts
(ctxs=..., filters=filters@entry=0x0, accept_null=false,
block=block@entry=0x7f957b02a3b0,
result_filter=result_filter@entry=0x7f9658ccccc0, can_filter_all=0x7f9658cccbc7)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exprs/vexpr_context.cpp:174
#27 0x0000561dbdd2131f in
doris::vectorized::VExprContext::execute_conjuncts_and_filter_block (ctxs=...,
block=0x7f957b02a3b0,
columns_to_filter=..., column_to_keep=6, filter=...) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exprs/vexpr_context.cpp:354
#28 0x0000561db8f49450 in
doris::segment_v2::SegmentIterator::_execute_common_expr
(this=this@entry=0x7f954e20a000,
sel_rowid_idx=0x7f955c0d2000, selected_size=@0x7f9658ccce6e: 104,
block=block@entry=0x7f957b02a3b0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/olap/rowset/segment_v2/segment_iterator.cpp:2338
#29 0x0000561db8f482f8 in
doris::segment_v2::SegmentIterator::_next_batch_internal (this=0x7f954e20a000,
block=0x7f957b02a3b0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/olap/rowset/segment_v2/segment_iterator.cpp:2230
#30 0x0000561db8f45212 in
doris::segment_v2::SegmentIterator::next_batch(doris::vectorized::Block*)::$_0::operator()()
const (
this=<optimized out>) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/olap/rowset/segment_v2/segment_iterator.cpp:1953
#31 doris::segment_v2::SegmentIterator::next_batch (this=0x7f954e20a000,
block=0x6)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/olap/rowset/segment_v2/segment_iterator.cpp:1952
#32 0x0000561db8ee49bc in
doris::segment_v2::LazyInitSegmentIterator::next_batch (this=0x7f953bc71f80,
block=0x7f957b02a3b0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/olap/rowset/segment_v2/lazy_init_segment_iterator.h:44
#33 0x0000561db8dab844 in doris::BetaRowsetReader::next_block
(this=0x7f9a4e215800, block=0x7f957b02a3b0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/olap/rowset/beta_rowset_reader.cpp:377
#34 0x0000561dc2c9413d in
doris::vectorized::VCollectIterator::Level0Iterator::_refresh
(this=0x7f953ba137a0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/olap/vcollect_iterator.h:256
#35 doris::vectorized::VCollectIterator::Level0Iterator::refresh_current_row
(this=this@entry=0x7f953ba137a0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/olap/vcollect_iterator.cpp:509
#36 0x0000561dc2c93bf4 in
doris::vectorized::VCollectIterator::Level0Iterator::init (this=0x7f953ba137a0,
get_data_by_ref=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/olap/vcollect_iterator.cpp:461
#37 0x0000561dc2c91002 in doris::vectorized::VCollectIterator::build_heap
(this=0x7f957a52bb30, rs_readers=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/olap/vcollect_iterator.cpp:125
#38 0x0000561dc2c7e1f2 in doris::vectorized::BlockReader::_init_collect_iter
(this=this@entry=0x7f957a52b400, read_params=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/olap/block_reader.cpp:153
#39 0x0000561dc2c7f191 in doris::vectorized::BlockReader::init
(this=<optimized out>, read_params=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/olap/block_reader.cpp:226
#40 0x0000561dc3937869 in doris::vectorized::NewOlapScanner::open
(this=0x7f9a56270210, state=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exec/scan/new_olap_scanner.cpp:252
#41 0x0000561dbdcc5413 in doris::vectorized::ScannerScheduler::_scanner_scan
(ctx=..., scan_task=...)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exec/scan/scanner_scheduler.cpp:221
#42 0x0000561dbdcc62bd in
doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}::operator()() const::{lambda()#1}::operator()() const
(this=<optimized out>)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exec/scan/scanner_scheduler.cpp:154
#43
doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}::operator()() const (this=0x7f954e25d3c0)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/vec/exec/scan/scanner_scheduler.cpp:153
#44 std::__invoke_impl<void,
doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}&>(std::__invoke_other,
doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}&) (__f=...)
at
/data/home/lambxu/installs/ldb_toolchain_bak/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:61
#45 std::__invoke_r<void,
doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}&>(doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}&) (__fn=...)
at
/data/home/lambxu/installs/ldb_toolchain_bak/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/invoke.h:111
#46 std::_Function_handler<void (),
doris::vectorized::ScannerScheduler::submit(std::shared_ptr<doris::vectorized::ScannerContext>,
std::shared_ptr<doris::vectorized::ScanTask>)::$_1::operator()()
const::{lambda()#1}>::_M_invoke(std::_Any_data const&) (__functor=...)
at
/data/home/lambxu/installs/ldb_toolchain_bak/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:291
#47 0x0000561db962137a in doris::ThreadPool::dispatch_thread
(this=0x7f9a50f9d380)
at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/util/threadpool.cpp:602
#48 0x0000561db96159a1 in std::function<void ()>::operator()() const
(this=0x11a791)
at
/data/home/lambxu/installs/ldb_toolchain_bak/bin/../lib/gcc/x86_64-linux-gnu/11/../../../../include/c++/11/bits/std_function.h:560
#49 doris::Thread::supervise_thread (arg=0x7f969f569ce0) at
/data/home/lambxu/work/git/doris-3.1/doris/be/src/util/thread.cpp:498
#50 0x00007f9aca4a2215 in start_thread () from /lib64/libc.so.6
#51 0x00007f9aca524bdc in clone3 () from /lib64/libc.so.6
```
Assume that 1,2,3,4,5 is key columns of an agg mv, because the PreAgg is OFF
at scan node, all key columns should be in blocks.
if we select 1,2 column, with 4,5 column in where clause, then the slot ids
should be 1,2,4,5, and column ids in conjuncts is 2,3,
But the plan treat the agg mv as a dup mv, so these conjuncts are pushed
down to the scan node which belongs to an agg mv, these conjuncts will pick the
wrong column in block to exucute.
### Release note
None
### Check List (For Author)
- Test <!-- At least one of them must be included. -->
- [x] Regression test
- [ ] Unit Test
- [ ] Manual test (add detailed scripts or steps below)
- [ ] No need to test or manual test. Explain why:
- [ ] This is a refactor/code format and no logic has been changed.
- [ ] Previous test can cover this change.
- [ ] No code files have been changed.
- [ ] Other reason <!-- Add your reason? -->
- Behavior changed:
- [x] No.
- [ ] Yes. <!-- Explain the behavior change -->
- Does this need documentation?
- [x] No.
- [ ] Yes. <!-- Add document PR link here. eg:
https://github.com/apache/doris-website/pull/1214 -->
### Check List (For Reviewer who merge this PR)
- [ ] Confirm the release note
- [ ] Confirm test cases
- [ ] Confirm document
- [ ] Add branch pick label <!-- Add branch pick label that this PR should
merge into -->
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
