nirandaperera edited a comment on pull request #10845:
URL: https://github.com/apache/arrow/pull/10845#issuecomment-930800047
I added the `GrouperFastImpl::Find`. I tried reusing the
`GrouperFastImpl::ConsumeImpl`method, but it looks like **parallel** test cases
are failing. Following is a local stacktrace I get
```
__GI_raise 0x00007fa593a0818b
__GI_abort 0x00007fa5939e7859
arrow::util::CerrLog::~CerrLog logging.cc:72
arrow::util::CerrLog::~CerrLog logging.cc:74
arrow::util::ArrowLog::~ArrowLog logging.cc:250
arrow::util::TempVectorStack::release util.h:101
arrow::util::TempVectorHolder<unsigned char>::~TempVectorHolder util.h:119
arrow::compute::Hashing::HashMultiColumn key_hash.cc:274
arrow::compute::internal::(anonymous
namespace)::GrouperFastImpl::ConsumeImpl<true> hash_aggregate.cc:746
arrow::compute::internal::(anonymous namespace)::GrouperFastImpl::Find
hash_aggregate.cc:804
arrow::compute::HashSemiJoinNode<false>::ConsumeProbeBatch
hash_join_node.cc:373
arrow::compute::HashSemiJoinNode<false>::ConsumeCachedProbeBatches()::{lambda()#1}::operator()()
hash_join_node.cc:314
arrow::internal::FnOnce<void
()>::FnImpl<arrow::compute::HashSemiJoinNode<false>::ConsumeCachedProbeBatches()::{lambda()#1}>::invoke()
functional.h:152
arrow::internal::FnOnce<void ()>::operator()() && functional.h:140
arrow::internal::WorkerLoop thread_pool.cc:176
arrow::internal::ThreadPool::<lambda()>::operator()(void) const
thread_pool.cc:336
std::__invoke_impl<void,
arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
>(std::__invoke_other, arrow::internal::ThreadPool::<lambda()> &&) invoke.h:60
std::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
>(arrow::internal::ThreadPool::<lambda()> &&) invoke.h:95
std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> >::_M_invoke<0>(std::_Index_tuple<0>) thread:244
std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> >::operator()(void) thread:251
std::thread::_State_impl<std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > >::_M_run(void) thread:195
<unknown> 0x00007fa594612de4
start_thread 0x00007fa593995609
clone 0x00007fa593ae4293
```
@michalursa I see that the new PR #11150 contains these test cases. I am
wondering if this is something you encountered previously.
--
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]
