pitrou commented on issue #43057:
URL: https://github.com/apache/arrow/issues/43057#issuecomment-2328203627
Also, the backtrace in the main thread looks like this. Other threads are
sleeping:
```
#0 0x00007faf45ac3170 in __lll_lock_wait () from
/lib/x86_64-linux-gnu/libpthread.so.0
#1 0x00007faf45abb0a3 in pthread_mutex_lock () from
/lib/x86_64-linux-gnu/libpthread.so.0
#2 0x00007faf48720685 in __gthread_mutex_lock () at
/usr/include/x86_64-linux-gnu/c++/9/bits/gthr-default.h:749
#3 0x00007faf48720bb4 in std::mutex::lock () at
/usr/include/c++/9/bits/std_mutex.h:100
#4 0x00007faf4a304979 in arrow::util::Mutex::Lock () at
/arrow/cpp/src/arrow/util/mutex.cc:56
#5 0x00007faf4cd6ad03 in
arrow::MergedGenerator<arrow::dataset::EnumeratedRecordBatch>::OuterCallback::operator()(arrow::Result<std::function<arrow::Future<
arrow::dataset::EnumeratedRecordBatch> ()> > const&) () at
/arrow/cpp/src/arrow/util/async_generator.h:1371
#6 0x00007faf4cd6804d in
arrow::Future<std::function<arrow::Future<arrow::dataset::EnumeratedRecordBatch>
()> >::WrapResultOnComplete::Callback<arrow::Merge
dGenerator<arrow::dataset::EnumeratedRecordBatch>::OuterCallback>::operator()(arrow::FutureImpl
const&) && () at /arrow/cpp/src/arrow/util/future.h:442
#7 0x00007faf4cd66493 in arrow::internal::FnOnce<void (arrow::FutureImpl
const&)>::FnImpl<arrow::Future<std::function<arrow::Future<arrow::dataset::Enumerat
edRecordBatch> ()>
>::WrapResultOnComplete::Callback<arrow::MergedGenerator<arrow::dataset::EnumeratedRecordBatch>::OuterCallback>
>::invoke(arrow::FutureImp
l const&) () at /arrow/cpp/src/arrow/util/functional.h:152
#8 0x00007faf4a2bd3d2 in arrow::internal::FnOnce<void (arrow::FutureImpl
const&)>::operator()(arrow::FutureImpl const&) && ()
at /arrow/cpp/src/arrow/util/functional.h:140
#9 0x00007faf4a2bc35d in
arrow::ConcreteFutureImpl::AddCallback(arrow::internal::FnOnce<void
(arrow::FutureImpl const&)>, arrow::CallbackOptions)::{lambda(a
rrow::FutureImpl const&)#1}::operator()(arrow::FutureImpl const&) () at
/arrow/cpp/src/arrow/util/future.cc:58
#10 0x00007faf4a2c2d0d in arrow::internal::FnOnce<void (arrow::FutureImpl
const&)>::FnImpl<arrow::ConcreteFutureImpl::AddCallback(arrow::internal::FnOnce<voi
d (arrow::FutureImpl const&)>,
arrow::CallbackOptions)::{lambda(arrow::FutureImpl
const&)#1}>::invoke(arrow::FutureImpl const&) ()
at /arrow/cpp/src/arrow/util/functional.h:152
#11 0x00007faf4a2bd3d2 in arrow::internal::FnOnce<void (arrow::FutureImpl
const&)>::operator()(arrow::FutureImpl const&) && ()
at /arrow/cpp/src/arrow/util/functional.h:140
#12 0x00007faf4a2bcc0c in arrow::ConcreteFutureImpl::RunOrScheduleCallback
() at /arrow/cpp/src/arrow/util/future.cc:110
#13 0x00007faf4a2bc60a in
arrow::ConcreteFutureImpl::AddCallback(arrow::internal::FnOnce<void
(arrow::FutureImpl const&)>, arrow::CallbackOptions) ()
at /arrow/cpp/src/arrow/util/future.cc:64
#14 0x00007faf4a2ba36a in
arrow::FutureImpl::AddCallback(arrow::internal::FnOnce<void (arrow::FutureImpl
const&)>, arrow::CallbackOptions) ()
at /arrow/cpp/src/arrow/util/future.cc:229
#15 0x00007faf4cd35839 in
arrow::Future<std::function<arrow::Future<arrow::dataset::EnumeratedRecordBatch>
()> >::AddCallback<arrow::MergedGenerator<arrow::d
ataset::EnumeratedRecordBatch>::OuterCallback,
arrow::Future<std::function<arrow::Future<arrow::dataset::EnumeratedRecordBatch>
()> >::WrapResultOnComplete::
Callback<arrow::MergedGenerator<arrow::dataset::EnumeratedRecordBatch>::OuterCallback>
>(arrow::MergedGenerator<arrow::dataset::EnumeratedRecordBatch>::Outer
Callback, arrow::CallbackOptions) const () at
/arrow/cpp/src/arrow/util/future.h:493
#16 0x00007faf4cd2bee8 in
arrow::MergedGenerator<arrow::dataset::EnumeratedRecordBatch>::operator() () at
/arrow/cpp/src/arrow/util/async_generator.h:1098
#17 0x00007faf4cd212de in
std::_Function_handler<arrow::Future<arrow::dataset::EnumeratedRecordBatch> (),
arrow::MergedGenerator<arrow::dataset::EnumeratedRe
cordBatch> >::_M_invoke(std::_Any_data const&) () at
/usr/include/c++/9/bits/std_function.h:286
#18 0x00007faf4cd059cc in
std::function<arrow::Future<arrow::dataset::EnumeratedRecordBatch>
()>::operator()() const ()
at /usr/include/c++/9/bits/std_function.h:688
#19 0x00007faf4cd2c4ba in
arrow::ReadaheadGenerator<arrow::dataset::EnumeratedRecordBatch>::operator() ()
at /arrow/cpp/src/arrow/util/async_generator.h:777
#20 0x00007faf4cd21530 in
std::_Function_handler<arrow::Future<arrow::dataset::EnumeratedRecordBatch> (),
arrow::ReadaheadGenerator<arrow::dataset::Enumerate
dRecordBatch> >::_M_invoke(std::_Any_data const&) () at
/usr/include/c++/9/bits/std_function.h:286
#21 0x00007faf4cd059cc in
std::function<arrow::Future<arrow::dataset::EnumeratedRecordBatch>
()>::operator()() const ()
at /usr/include/c++/9/bits/std_function.h:688
#22 0x00007faf4cd2cdae in
arrow::MappingGenerator<arrow::dataset::EnumeratedRecordBatch,
std::optional<arrow::compute::ExecBatch> >::operator() ()
at /arrow/cpp/src/arrow/util/async_generator.h:163
#23 0x00007faf4cd21c61 in
std::_Function_handler<arrow::Future<std::optional<arrow::compute::ExecBatch> >
(), arrow::MappingGenerator<arrow::dataset::Enumera
tedRecordBatch, std::optional<arrow::compute::ExecBatch> >
>::_M_invoke(std::_Any_data const&) () at
/usr/include/c++/9/bits/std_function.h:286
#24 0x0000563c62c625f6 in
std::function<arrow::Future<std::optional<arrow::compute::ExecBatch> >
()>::operator()() const ()
at /usr/include/c++/9/bits/std_function.h:688
#25 0x00007faf4b4687cb in operator() () at
/arrow/cpp/src/arrow/acero/source_node.cc:201
#26 0x00007faf4b46c72f in Loop<arrow::acero::(anonymous
namespace)::SourceNode::StartProducing()::<lambda()> >(void) ()
at /arrow/cpp/src/arrow/util/future.h:852
#27 0x00007faf4b468d73 in StartProducing () at
/arrow/cpp/src/arrow/acero/source_node.cc:219
#28 0x00007faf4b380e1f in operator() () at
/arrow/cpp/src/arrow/acero/exec_plan.cc:175
#29 0x00007faf4b3951e3 in invoke () at
/arrow/cpp/src/arrow/util/functional.h:152
#30 0x00007faf4a24ac09 in arrow::internal::FnOnce<arrow::Status
(arrow::util::AsyncTaskScheduler*)>::operator()(arrow::util::AsyncTaskScheduler*)
&& ()
at /arrow/cpp/src/arrow/util/functional.h:140
#31 0x00007faf4a2414cb in
arrow::util::AsyncTaskScheduler::Make(arrow::internal::FnOnce<arrow::Status
(arrow::util::AsyncTaskScheduler*)>, arrow::internal::F
nOnce<void (arrow::Status const&)>, arrow::StopToken) () at
/arrow/cpp/src/arrow/util/async_util.cc:471
#32 0x00007faf4b3815a8 in StartProducing () at
/arrow/cpp/src/arrow/acero/exec_plan.cc:193
#33 0x00007faf4b38332a in arrow::acero::ExecPlan::StartProducing () at
/arrow/cpp/src/arrow/acero/exec_plan.cc:439
#34 0x00007faf4cce1ae6 in ScanBatchesUnorderedAsync () at
/arrow/cpp/src/arrow/dataset/scanner.cc:460
#35 0x00007faf4cce4b0e in ToTableAsync () at
/arrow/cpp/src/arrow/dataset/scanner.cc:703
#36 0x00007faf4cce0817 in operator() () at
/arrow/cpp/src/arrow/dataset/scanner.cc:398
#37 0x00007faf4ccfaf57 in invoke () at
/arrow/cpp/src/arrow/util/functional.h:152
#38 0x00007faf4cd108d1 in
arrow::internal::FnOnce<arrow::Future<std::shared_ptr<arrow::Table> >
(arrow::internal::Executor*)>::operator()(arrow::internal::Ex
ecutor*) && () at /arrow/cpp/src/arrow/util/functional.h:140
#39 0x00007faf4cd1d0b2 in
arrow::internal::SerialExecutor::Run<std::shared_ptr<arrow::Table>,
arrow::Result<std::shared_ptr<arrow::Table> > >(arrow::internal
::FnOnce<arrow::Future<std::shared_ptr<arrow::Table> >
(arrow::internal::Executor*)>) () at /arrow/cpp/src/arrow/util/thread_pool.h:418
#40 0x00007faf4cd10a13 in
arrow::internal::SerialExecutor::RunInSerialExecutor<std::shared_ptr<arrow::Table>,
arrow::Future<std::shared_ptr<arrow::Table> >,
arrow::Result<std::shared_ptr<arrow::Table> >
>(arrow::internal::FnOnce<arrow::Future<std::shared_ptr<arrow::Table> >
(arrow::internal::Executor*)>) ()
at /arrow/cpp/src/arrow/util/thread_pool.h:300
#41 0x00007faf4cd04eaa in
arrow::internal::RunSynchronously<arrow::Future<std::shared_ptr<arrow::Table>
>, std::shared_ptr<arrow::Table> >(arrow::internal::F
nOnce<arrow::Future<std::shared_ptr<arrow::Table> >
(arrow::internal::Executor*)>, bool) () at
/arrow/cpp/src/arrow/util/thread_pool.h:590
#42 0x00007faf4cce0898 in ToTable () at
/arrow/cpp/src/arrow/dataset/scanner.cc:399
#43 0x0000563c62cb7fca in
arrow::dataset::DatasetEncryptionTestBase::TestScanDataset () at
/arrow/cpp/src/arrow/dataset/file_parquet_encryption_test.cc:159
#44 0x0000563c62cb2006 in
arrow::dataset::DatasetEncryptionTest_WriteReadDatasetWithEncryption_Test::TestBody
()
at /arrow/cpp/src/arrow/dataset/file_parquet_encryption_test.cc:208
#45 0x00007faf4b6915e2 in
testing::internal::HandleSehExceptionsInMethodIfSupported<testing::Test, void>
()
at _deps/googletest-src/googletest/src/gtest.cc:2607
#46 0x00007faf4b689377 in
testing::internal::HandleExceptionsInMethodIfSupported<testing::Test, void> ()
at _deps/googletest-src/googletest/src/gtest.cc:2643
#47 0x00007faf4b65c7ae in testing::Test::Run () at
_deps/googletest-src/googletest/src/gtest.cc:2682
#48 0x00007faf4b65d1f0 in testing::TestInfo::Run () at
_deps/googletest-src/googletest/src/gtest.cc:2861
#49 0x00007faf4b65db0a in testing::TestSuite::Run () at
_deps/googletest-src/googletest/src/gtest.cc:3015
#50 0x00007faf4b66d5c2 in testing::internal::UnitTestImpl::RunAllTests () at
_deps/googletest-src/googletest/src/gtest.cc:5855
#51 0x00007faf4b6926a3 in
testing::internal::HandleSehExceptionsInMethodIfSupported<testing::internal::UnitTestImpl,
bool> ()
at _deps/googletest-src/googletest/src/gtest.cc:2607
#52 0x00007faf4b68a63d in
testing::internal::HandleExceptionsInMethodIfSupported<testing::internal::UnitTestImpl,
bool> ()
at _deps/googletest-src/googletest/src/gtest.cc:2643
#53 0x00007faf4b66bcd9 in testing::UnitTest::Run () at
_deps/googletest-src/googletest/src/gtest.cc:5438
#54 0x00007faf4b6c5b2a in RUN_ALL_TESTS () at
_deps/googletest-src/googletest/include/gtest/gtest.h:2490
#55 0x00007faf4b6c5aac in main () at
_deps/googletest-src/googletest/src/gtest_main.cc:52
#56 0x00007faf45ff4083 in __libc_start_main () from
/lib/x86_64-linux-gnu/libc.so.6
#57 0x0000563c62c4907e in _start ()
```
--
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]
