[
https://issues.apache.org/jira/browse/ARROW-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated ARROW-14539:
-----------------------------------
Labels: pull-request-available query-engine (was: query-engine)
> [C++] Dataset scanner test failing a DCHECK
> -------------------------------------------
>
> Key: ARROW-14539
> URL: https://issues.apache.org/jira/browse/ARROW-14539
> Project: Apache Arrow
> Issue Type: Bug
> Components: C++
> Reporter: David Li
> Assignee: Weston Pace
> Priority: Major
> Labels: pull-request-available, query-engine
> Time Spent: 10m
> Remaining Estimate: 0h
>
> While from a PR, this appears unrelated to the PR.
> Log: [https://github.com/apache/arrow/runs/4069711313?check_suite_focus=true]
> {noformat}
> [ RUN ]
> TestScannerThreading/TestScanner.TakeIndices/7AsyncThreaded2d16b1024r
> /Users/runner/work/arrow/arrow/cpp/src/arrow/util/future.cc:309: Check
> failed: !IsFutureFinished(state_) Future already marked finished
> 0 libarrow.700.0.0.dylib 0x0000000108fe3ee4
> _ZN5arrow4util7CerrLog14PrintBackTraceEv + 52
> 1 libarrow.700.0.0.dylib 0x0000000108fe3e02
> _ZN5arrow4util7CerrLogD2Ev + 98
> 2 libarrow.700.0.0.dylib 0x0000000108fe3d65
> _ZN5arrow4util7CerrLogD1Ev + 21
> 3 libarrow.700.0.0.dylib 0x0000000108fe3d8c
> _ZN5arrow4util7CerrLogD0Ev + 28
> 4 libarrow.700.0.0.dylib 0x0000000108fe3c72
> _ZN5arrow4util8ArrowLogD2Ev + 82
> 5 libarrow.700.0.0.dylib 0x0000000108fe3ca5
> _ZN5arrow4util8ArrowLogD1Ev + 21
> 6 libarrow.700.0.0.dylib 0x0000000108fab4d0
> _ZN5arrow18ConcreteFutureImpl22DoMarkFinishedOrFailedENS_11FutureStateE + 304
> 7 libarrow.700.0.0.dylib 0x0000000108fa601a
> _ZN5arrow18ConcreteFutureImpl12DoMarkFailedEv + 26
> 8 libarrow.700.0.0.dylib 0x0000000108fa5fed
> _ZN5arrow10FutureImpl10MarkFailedEv + 29
> 9 arrow-dataset-scanner-test 0x00000001040357f8
> _ZN5arrow6FutureINS_8internal5EmptyEE14DoMarkFinishedENS_6ResultIS2_EE + 168
> 10 arrow-dataset-scanner-test 0x0000000104035562
> _ZN5arrow6FutureINS_8internal5EmptyEE12MarkFinishedIS2_vEEvNS_6StatusE + 98
> 11 libarrow.700.0.0.dylib 0x0000000108f3673a
> _ZZN5arrow4util14AsyncTaskGroup15AddTaskUnlockedERKNS_6FutureINS_8internal5EmptyEEENS0_5Mutex5GuardEENK3$_1clERKNS_6StatusE
> + 170
> 12 libarrow.700.0.0.dylib 0x0000000108f3668a
> _ZNO5arrow6FutureINS_8internal5EmptyEE21WrapStatusyOnComplete8CallbackIZNS_4util14AsyncTaskGroup15AddTaskUnlockedERKS3_NS6_5Mutex5GuardEE3$_1EclERKNS_10FutureImplE
> + 58
> 13 libarrow.700.0.0.dylib 0x0000000108f3661b
> _ZN5arrow8internal6FnOnceIFvRKNS_10FutureImplEEE6FnImplINS_6FutureINS0_5EmptyEE21WrapStatusyOnComplete8CallbackIZNS_4util14AsyncTaskGroup15AddTaskUnlockedERKSA_NSD_5Mutex5GuardEE3$_1EEE6invokeES4_
> + 59
> 14 libarrow.700.0.0.dylib 0x0000000108fac4c5
> _ZNO5arrow8internal6FnOnceIFvRKNS_10FutureImplEEEclES4_ + 85
> 15 libarrow.700.0.0.dylib 0x0000000108fabb6b
> _ZN5arrow18ConcreteFutureImpl21RunOrScheduleCallbackERKNSt3__110shared_ptrINS_10FutureImplEEEONS3_14CallbackRecordEb
> + 779
> 16 libarrow.700.0.0.dylib 0x0000000108fab64a
> _ZN5arrow18ConcreteFutureImpl22DoMarkFinishedOrFailedENS_11FutureStateE + 682
> 17 libarrow.700.0.0.dylib 0x0000000108fa601a
> _ZN5arrow18ConcreteFutureImpl12DoMarkFailedEv + 26
> 18 libarrow.700.0.0.dylib 0x0000000108fa5fed
> _ZN5arrow10FutureImpl10MarkFailedEv + 29
> 19 arrow-dataset-scanner-test 0x00000001040357f8
> _ZN5arrow6FutureINS_8internal5EmptyEE14DoMarkFinishedENS_6ResultIS2_EE + 168
> 20 arrow-dataset-scanner-test 0x0000000104035562
> _ZN5arrow6FutureINS_8internal5EmptyEE12MarkFinishedIS2_vEEvNS_6StatusE + 98
> 21 libarrow.700.0.0.dylib 0x00000001093f55d4
> _ZZN5arrow8internal8Executor6SubmitIZZNS_7compute7MapNode10SubmitTaskENSt3__18functionIFNS_6ResultINS3_9ExecBatchEEES8_EEES8_ENK3$_1clEvEUlvE_JENS_6FutureINS0_5EmptyEEEEENS7_IT1_EENS0_9TaskHintsENS_9StopTokenEOT_DpOT0_EN3$_4clERKNS_6StatusE
> + 100
> 22 libarrow.700.0.0.dylib 0x00000001093f550b
> _ZN5arrow8internal6FnOnceIFvRKNS_6StatusEEE6FnImplIZNS0_8Executor6SubmitIZZNS_7compute7MapNode10SubmitTaskENSt3__18functionIFNS_6ResultINSA_9ExecBatchEEESF_EEESF_ENK3$_1clEvEUlvE_JENS_6FutureINS0_5EmptyEEEEENSE_IT1_EENS0_9TaskHintsENS_9StopTokenEOT_DpOT0_E3$_4E6invokeES4_
> + 59
> 23 libarrow.700.0.0.dylib 0x0000000109016095
> _ZNO5arrow8internal6FnOnceIFvRKNS_6StatusEEEclES4_ + 85
> 24 libarrow.700.0.0.dylib 0x000000010902121e
> _ZN5arrow8internalL10WorkerLoopENSt3__110shared_ptrINS0_10ThreadPool5StateEEENS1_15__list_iteratorINS1_6threadEPvEE
> + 974
> 25 libarrow.700.0.0.dylib 0x0000000109020e1f
> _ZZN5arrow8internal10ThreadPool21LaunchWorkersUnlockedEiENK3$_3clEv + 95
> 26 libarrow.700.0.0.dylib 0x0000000109020d6d
> _ZNSt3__1L8__invokeIZN5arrow8internal10ThreadPool21LaunchWorkersUnlockedEiE3$_3JEEEDTclclsr3std3__1E7forwardIT_Efp_Espclsr3std3__1E7forwardIT0_Efp0_EEEOS5_DpOS6_
> + 29
> 27 libarrow.700.0.0.dylib 0x0000000109020cd5
> _ZNSt3__1L16__thread_executeINS_10unique_ptrINS_15__thread_structENS_14default_deleteIS2_EEEEZN5arrow8internal10ThreadPool21LaunchWorkersUnlockedEiE3$_3JEJEEEvRNS_5tupleIJT_T0_DpT1_EEENS_15__tuple_indicesIJXspT2_EEEE
> + 37
> 28 libarrow.700.0.0.dylib 0x0000000109020426
> _ZNSt3__1L14__thread_proxyINS_5tupleIJNS_10unique_ptrINS_15__thread_structENS_14default_deleteIS3_EEEEZN5arrow8internal10ThreadPool21LaunchWorkersUnlockedEiE3$_3EEEEEPvSC_
> + 118
> 29 libsystem_pthread.dylib 0x00007fff7040f109 _pthread_start +
> 148
> 30 libsystem_pthread.dylib 0x00007fff7040ab8b thread_start + 15
> Found core dump, printing backtrace:
> (lldb) target create --core "core.arrow-dataset-sc.74586"
> Core file
> '/Users/runner/work/arrow/arrow/build/cpp/build/test-work/arrow-dataset-scanner-test/core.arrow-dataset-sc.74586'
> (x86_64) was loaded.(lldb) thread backtrace all -e true
> frame #35: 0x0000000108fabb6b
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::RunOrScheduleCallback(self=std::__1::shared_ptr<arrow::FutureImpl>::element_type
> @ 0x00007f9b5d4bdbf0 strong=3 weak=3, callback_record=0x00007f9b5d41b480,
> in_add_callback=false) at future.cc:298:7
> frame #36: 0x0000000108fab64a
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::DoMarkFinishedOrFailed(this=0x00007f9b5d4bdbf0,
> state=SUCCESS) at future.cc:327:7
> frame #37: 0x0000000108fa5fca
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::DoMarkFinished(this=0x00007f9b5d4bdbf0)
> at future.cc:231:27
> frame #38: 0x0000000108fa5f9d
> libarrow.700.0.0.dylib`arrow::FutureImpl::MarkFinished(this=0x00007f9b5d4bdbf0)
> at future.cc:383:60
> frame #39: 0x00000001040357cd
> arrow-dataset-scanner-test`arrow::Future<arrow::internal::Empty>::DoMarkFinished(this=0x000070000d9f1c08,
> res=<unavailable>) at future.h:712:14
> frame #40: 0x0000000104035562 arrow-dataset-scanner-test`void
> arrow::Future<arrow::internal::Empty>::MarkFinished<arrow::internal::Empty,
> void>(this=0x000070000d9f1c08, s=<unavailable>) at future.h:463:12
> frame #41: 0x00000001093f4f0d
> libarrow.700.0.0.dylib`std::__1::enable_if<((!(std::is_void<arrow::Status>::value))
> && (!(is_future<arrow::Status>::value))) &&
> ((!(arrow::Future<arrow::internal::Empty>::is_empty)) ||
> (std::is_same<arrow::Status, arrow::Status>::value)), void>::type
> arrow::detail::ContinueFuture::operator(this=0x00007f9b5d4bdcd0,
> next=Future<arrow::internal::Empty> @ 0x000070000d9f1c08,
> f=0x00007f9b5d4bdcf0)<arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&, arrow::Status, arrow::Future<arrow::internal::Empty>
> >(arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&) const at future.h:148:10
> frame #42: 0x00000001093f4df6
> libarrow.700.0.0.dylib`decltype(__f=0x00007f9b5d4bdcd0,
> __args=0x00007f9b5d4bdce0,
> __args=0x00007f9b5d4bdcf0)(std::__1::forward<arrow::Future<arrow::internal::Empty>&>(fp0),
>
> std::__1::forward<arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&>(fp0))) std::__1::__invoke<arrow::detail::ContinueFuture&,
> arrow::Future<arrow::internal::Empty>&,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&>(arrow::detail::ContinueFuture&,
> arrow::Future<arrow::internal::Empty>&,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&) at type_traits:3545:1
> frame #43: 0x00000001093f4d8d
> libarrow.700.0.0.dylib`std::__1::__bind_return<arrow::detail::ContinueFuture,
> std::__1::tuple<arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>, std::__1::tuple<>,
> __is_valid_bind_return<arrow::detail::ContinueFuture,
> std::__1::tuple<arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>, std::__1::tuple<> >::value>::type
> std::__1::__apply_functor<arrow::detail::ContinueFuture,
> std::__1::tuple<arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(__f=0x00007f9b5d4bdcd0,
> __bound_args=size=2, (null)=__tuple_indices<0, 1> @ 0x000070000d9f1c68,
> __args=size=0)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>, 0ul, 1ul, std::__1::tuple<>
> >(arrow::detail::ContinueFuture&,
> std::__1::tuple<arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>&, std::__1::__tuple_indices<0ul, 1ul>,
> std::__1::tuple<>&&) at functional:2845:12
> frame #44: 0x00000001093f4d29
> libarrow.700.0.0.dylib`std::__1::__bind_return<arrow::detail::ContinueFuture,
> std::__1::tuple<arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>, std::__1::tuple<>,
> __is_valid_bind_return<arrow::detail::ContinueFuture,
> std::__1::tuple<arrow::Future<arrow::internal::Empty>,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>, std::__1::tuple<> >::value>::type
> std::__1::__bind<arrow::detail::ContinueFuture,
> arrow::Future<arrow::internal::Empty>&,
> arrow::compute::MapNode::SubmitTask(this=0x00007f9b5d4bdcd0)>,
> arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()>::operator()<>() at functional:2878:20
> frame #45: 0x00000001093f4ca6
> libarrow.700.0.0.dylib`arrow::internal::FnOnce<void
> ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture,
> arrow::Future<arrow::internal::Empty>&,
> arrow::compute::MapNode::SubmitTask(this=0x00007f9b5d4bdcc0)>,
> arrow::compute::ExecBatch)::$_1::operator()() const::'lambda'()> >::invoke()
> at functional.h:152:42
> frame #46: 0x0000000109015fdd
> libarrow.700.0.0.dylib`arrow::internal::FnOnce<void
> ()>::operator(this=0x000070000d9f1e18)() && at functional.h:140:17
> frame #47: 0x0000000109021179
> libarrow.700.0.0.dylib`arrow::internal::WorkerLoop(state=std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type
> @ 0x00007f9b5d4be638 strong=7 weak=1, it=std::__1::list<std::__1::thread,
> std::__1::allocator<std::__1::thread> >::iterator @ 0x000070000d9f1eb8) at
> thread_pool.cc:177:11
> frame #48: 0x0000000109020e1f
> libarrow.700.0.0.dylib`arrow::internal::ThreadPool::LaunchWorkersUnlocked(this=0x00007f9b5d604488)::$_3::operator()()
> const at thread_pool.cc:344:7
> frame #49: 0x0000000109020d6d
> libarrow.700.0.0.dylib`decltype(__f=0x00007f9b5d604488)::$_3>(fp)())
> std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3&&)
> at type_traits:3545:1
> frame #50: 0x0000000109020cd5 libarrow.700.0.0.dylib`void
> std::__1::__thread_execute<std::__1::unique_ptr<std::__1::__thread_struct,
> std::__1::default_delete<std::__1::__thread_struct> >,
> arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>(__t=size=2,
> (null)=__tuple_indices<> @ 0x000070000d9f1f58)::$_3>&,
> std::__1::__tuple_indices<>) at thread:273:5
> frame #51: 0x0000000109020426 libarrow.700.0.0.dylib`void*
> std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct,
> std::__1::default_delete<std::__1::__thread_struct> >,
> arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>
> >(__vp=0x00007f9b5d604480) at thread:284:5
> frame #52: 0x00007fff7040f109 libsystem_pthread.dylib`_pthread_start + 148
> frame #53: 0x00007fff7040ab8b libsystem_pthread.dylib`thread_start + 15
> thread #4, stop reason = signal SIGSTOP
> frame #0: 0x00007fff7034e33a libsystem_kernel.dylib`__pthread_kill + 10
> frame #1: 0x00007fff7040ee60 libsystem_pthread.dylib`pthread_kill + 430
> frame #2: 0x00007fff702d5808 libsystem_c.dylib`abort + 120
> frame #3: 0x0000000108fe3e0c
> libarrow.700.0.0.dylib`arrow::util::CerrLog::~CerrLog(this=0x00007f9b5d60d390)
> at logging.cc:72:7
> frame #4: 0x0000000108fe3d65
> libarrow.700.0.0.dylib`arrow::util::CerrLog::~CerrLog(this=0x00007f9b5d60d390)
> at logging.cc:66:22
> frame #5: 0x0000000108fe3d8c
> libarrow.700.0.0.dylib`arrow::util::CerrLog::~CerrLog(this=0x00007f9b5d60d390)
> at logging.cc:66:22
> frame #6: 0x0000000108fe3c72
> libarrow.700.0.0.dylib`arrow::util::ArrowLog::~ArrowLog(this=0x000070000da746e8)
> at logging.cc:250:5
> frame #7: 0x0000000108fe3ca5
> libarrow.700.0.0.dylib`arrow::util::ArrowLog::~ArrowLog(this=0x000070000da746e8)
> at logging.cc:248:23
> frame #8: 0x0000000108fab4d0
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::DoMarkFinishedOrFailed(this=0x00007f9b5d511d40,
> state=FAILURE) at future.cc:309:7
> frame #9: 0x0000000108fa601a
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::DoMarkFailed(this=0x00007f9b5d511d40)
> at future.cc:233:25
> frame #10: 0x0000000108fa5fed
> libarrow.700.0.0.dylib`arrow::FutureImpl::MarkFailed(this=0x00007f9b5d511d40)
> at future.cc:385:58
> frame #11: 0x00000001040357f8
> arrow-dataset-scanner-test`arrow::Future<arrow::internal::Empty>::DoMarkFinished(this=0x00007f9b5d511bd8,
> res=<unavailable>) at future.h:714:14
> frame #12: 0x0000000104035562 arrow-dataset-scanner-test`void
> arrow::Future<arrow::internal::Empty>::MarkFinished<arrow::internal::Empty,
> void>(this=0x00007f9b5d511bd8, s=<unavailable>) at future.h:463:12
> frame #13: 0x0000000108f3673a
> libarrow.700.0.0.dylib`arrow::util::AsyncTaskGroup::AddTaskUnlocked(this=0x00007f9b5d4281d8,
> st=0x00007f9b5d607af0)::$_1::operator()(arrow::Status const&) const at
> async_util.cc:75:23
> frame #14: 0x0000000108f3668a
> libarrow.700.0.0.dylib`arrow::Future<arrow::internal::Empty>::WrapStatusyOnComplete::Callback<arrow::util::AsyncTaskGroup::AddTaskUnlocked(this=0x00007f9b5d4281d8,
> impl=0x00007f9b5d4332e0)::$_1>::operator()(arrow::FutureImpl const&) && at
> future.h:509:9
> frame #15: 0x0000000108f3661b
> libarrow.700.0.0.dylib`arrow::internal::FnOnce<void (arrow::FutureImpl
> const&)>::FnImpl<arrow::Future<arrow::internal::Empty>::WrapStatusyOnComplete::Callback<arrow::util::AsyncTaskGroup::AddTaskUnlocked(this=0x00007f9b5d4281d0,
> a=0x00007f9b5d4332e0)::$_1> >::invoke(arrow::FutureImpl const&) at
> functional.h:152:42
> frame #16: 0x0000000108fac4c5
> libarrow.700.0.0.dylib`arrow::internal::FnOnce<void (arrow::FutureImpl
> const&)>::operator(this=0x00007f9b5d48fb10,
> a=0x00007f9b5d4332e0)(arrow::FutureImpl const&) && at functional.h:140:17
> frame #17: 0x0000000108fabb6b
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::RunOrScheduleCallback(self=std::__1::shared_ptr<arrow::FutureImpl>::element_type
> @ 0x00007f9b5d4332e0 strong=3 weak=3, callback_record=0x00007f9b5d48fb10,
> in_add_callback=false) at future.cc:298:7
> frame #18: 0x0000000108fab64a
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::DoMarkFinishedOrFailed(this=0x00007f9b5d4332e0,
> state=FAILURE) at future.cc:327:7
> frame #19: 0x0000000108fa601a
> libarrow.700.0.0.dylib`arrow::ConcreteFutureImpl::DoMarkFailed(this=0x00007f9b5d4332e0)
> at future.cc:233:25
> frame #20: 0x0000000108fa5fed
> libarrow.700.0.0.dylib`arrow::FutureImpl::MarkFailed(this=0x00007f9b5d4332e0)
> at future.cc:385:58
> frame #21: 0x00000001040357f8
> arrow-dataset-scanner-test`arrow::Future<arrow::internal::Empty>::DoMarkFinished(this=0x000070000da74c60,
> res=<unavailable>) at future.h:714:14
> frame #22: 0x0000000104035562 arrow-dataset-scanner-test`void
> arrow::Future<arrow::internal::Empty>::MarkFinished<arrow::internal::Empty,
> void>(this=0x000070000da74c60, s=<unavailable>) at future.h:463:12
> frame #23: 0x00000001093f55d4
> libarrow.700.0.0.dylib`arrow::Result<arrow::Future<arrow::internal::Empty> >
> arrow::internal::Executor::Submit<arrow::compute::MapNode::SubmitTask(this=0x00007f9b5d457ea8,
> st=0x000070000da74e08)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'(), arrow::Future<arrow::internal::Empty>
> >(arrow::internal::TaskHints, arrow::StopToken,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&&)::$_4::operator()(arrow::Status const&) at
> thread_pool.h:158:15
> frame #24: 0x00000001093f550b
> libarrow.700.0.0.dylib`arrow::internal::FnOnce<void (arrow::Status
> const&)>::FnImpl<arrow::Result<arrow::Future<arrow::internal::Empty> >
> arrow::internal::Executor::Submit<arrow::compute::MapNode::SubmitTask(this=0x00007f9b5d457ea0,
> a=0x000070000da74e08)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'(), arrow::Future<arrow::internal::Empty>
> >(arrow::internal::TaskHints, arrow::StopToken,
> arrow::compute::MapNode::SubmitTask(std::__1::function<arrow::Result<arrow::compute::ExecBatch>
> (arrow::compute::ExecBatch)>, arrow::compute::ExecBatch)::$_1::operator()()
> const::'lambda'()&&)::$_4>::invoke(arrow::Status const&) at
> functional.h:152:42
> frame #25: 0x0000000109016095
> libarrow.700.0.0.dylib`arrow::internal::FnOnce<void (arrow::Status
> const&)>::operator(this=0x000070000da74e30,
> a=0x000070000da74e08)(arrow::Status const&) && at functional.h:140:17
> frame #26: 0x000000010902121e
> libarrow.700.0.0.dylib`arrow::internal::WorkerLoop(state=std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type
> @ 0x00007f9b5d4be638 strong=7 weak=1, it=std::__1::list<std::__1::thread,
> std::__1::allocator<std::__1::thread> >::iterator @ 0x000070000da74eb8) at
> thread_pool.cc:180:13
> frame #27: 0x0000000109020e1f
> libarrow.700.0.0.dylib`arrow::internal::ThreadPool::LaunchWorkersUnlocked(this=0x00007f9b5d430798)::$_3::operator()()
> const at thread_pool.cc:344:7
> frame #28: 0x0000000109020d6d
> libarrow.700.0.0.dylib`decltype(__f=0x00007f9b5d430798)::$_3>(fp)())
> std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3&&)
> at type_traits:3545:1
> frame #29: 0x0000000109020cd5 libarrow.700.0.0.dylib`void
> std::__1::__thread_execute<std::__1::unique_ptr<std::__1::__thread_struct,
> std::__1::default_delete<std::__1::__thread_struct> >,
> arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>(__t=size=2,
> (null)=__tuple_indices<> @ 0x000070000da74f58)::$_3>&,
> std::__1::__tuple_indices<>) at thread:273:5
> frame #30: 0x0000000109020426 libarrow.700.0.0.dylib`void*
> std::__1::__thread_proxy<std::__1::tuple<std::__1::unique_ptr<std::__1::__thread_struct,
> std::__1::default_delete<std::__1::__thread_struct> >,
> arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_3>
> >(__vp=0x00007f9b5d430790) at thread:284:5
> frame #31: 0x00007fff7040f109 libsystem_pthread.dylib`_pthread_start + 148
> frame #32: 0x00007fff7040ab8b libsystem_pthread.dylib`thread_start + 15
> ~/work/arrow/arrow/build/cpp/src/arrow/dataset {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
