[
https://issues.apache.org/jira/browse/ARROW-15361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585503#comment-17585503
]
Todd Farmer edited comment on ARROW-15361 at 8/26/22 4:17 PM:
--------------------------------------------------------------
This issue was last updated over 90 days ago, which may be an indication it is
no longer being actively worked. To better reflect the current state, the issue
is being unassigned per [project
policy|https://arrow.apache.org/docs/dev/developers/bug_reports.html#issue-assignment].
Please feel free to re-take assignment of the issue if it is being actively
worked, or if you plan to start that work soon.
was (Author: JIRAUSER288796):
This issue was last updated over 90 days ago, which may be an indication it is
no longer being actively worked. To better reflect the current state, the issue
is being unassigned per [project
policy|https://arrow.apache.org/docs/dev/developers/bug_reports.html#issue-assignment.
Please feel free to re-take assignment of the issue if it is being actively
worked, or if you plan to start that work soon.
> [C++][CI] Crash in arrow-compute-hash-join-node-test
> ----------------------------------------------------
>
> Key: ARROW-15361
> URL: https://issues.apache.org/jira/browse/ARROW-15361
> Project: Apache Arrow
> Issue Type: Bug
> Components: C++, Continuous Integration
> Reporter: Antoine Pitrou
> Priority: Major
>
> This is a sporadic crash, but this time we're lucky at least to have a
> full-blown traceback for all threads:
> https://github.com/pitrou/arrow/runs/4856592859?check_suite_focus=true#step:6:3099
> {code}
> Program terminated with signal SIGSEGV, Segmentation fault.
> #0 0x00000000000117bb in ?? ()
> [Current thread is 1 (Thread 0x7f66d7b7d700 (LWP 20461))]
> Thread 6 (Thread 0x7f66c7fff700 (LWP 20463)):
> #0 0x00007f66dc0ec065 in futex_abstimed_wait_cancelable (private=<optimized
> out>, abstime=0x7f66c7ffd4a0, expected=0, futex_word=0x7f66da40a794) at
> ../sysdeps/unix/sysv/linux/futex-internal.h:205
> #1 __pthread_cond_wait_common (abstime=0x7f66c7ffd4a0, mutex=0x7f66da40a7d8,
> cond=0x7f66da40a768) at pthread_cond_wait.c:539
> #2 __pthread_cond_timedwait (cond=0x7f66da40a768, mutex=0x7f66da40a7d8,
> abstime=0x7f66c7ffd4a0) at pthread_cond_wait.c:667
> #3 0x00007f66df325f26 in background_thread_sleep (tsdn=<optimized out>,
> interval=<optimized out>, info=0x7f66da40a760) at src/background_thread.c:255
> #4 background_work_sleep_once (ind=<optimized out>, info=<optimized out>,
> tsdn=<optimized out>) at src/background_thread.c:307
> #5 background_work (ind=<optimized out>, tsd=<optimized out>) at
> src/background_thread.c:497
> #6 background_thread_entry () at src/background_thread.c:522
> #7 0x00007f66dc0e56db in start_thread (arg=0x7f66c7fff700) at
> pthread_create.c:463
> #8 0x00007f66dc7bc71f in clone () at
> ../sysdeps/unix/sysv/linux/x86_64/clone.S:95
> Thread 5 (Thread 0x7f66da69e0c0 (LWP 20458)):
> #0 0x00007f66dd95b8db in arrow::bit_util::SetBitTo (bits=0x7f66d4e1e380
> "\367\323\373\335\377\335\377\332\337\347\367\337\033\327\372\375\375\317\274\376\377\375\376\263m\367\356\276\377\377\377\365\377\067\067\377\377\267o\177\377\331\373>\177\276_\277\377\377\337\372\377y\373o\277\001",
> i=457, bit_is_set=false) at /arrow/cpp/src/arrow/util/bit_util.h:317
> #1 0x00007f66dd95ca4f in arrow::TypedBufferBuilder<bool, void>::UnsafeAppend
> (this=0x7ffc6aee8e10, value=false) at
> /arrow/cpp/src/arrow/buffer_builder.h:336
> #2 0x00007f66dee66716 in arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::VisitTake<unsigned int,
> arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<Type>::GenerateOutput() [with Adapter =
> arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::TakeAdapter<unsigned int>; Type =
> arrow::BinaryType]::<lambda(int64_t)>, arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<Type>::GenerateOutput() [with Adapter =
> arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::TakeAdapter<unsigned int>; Type =
> arrow::BinaryType]::<lambda()> >(arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>::<lambda(int64_t)> &&,
> arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>::<lambda()> &&)
> (this=0x7ffc6aee8dd0, visit_valid=..., visit_null=...) at
> /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:1292
> #3 0x00007f66dee5b668 in arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::TakeAdapter<unsigned
> int>::Generate<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<Type>::GenerateOutput() [with Adapter =
> arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::TakeAdapter<unsigned int>; Type =
> arrow::BinaryType]::<lambda(int64_t)>, arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<Type>::GenerateOutput() [with Adapter =
> arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::TakeAdapter<unsigned int>; Type =
> arrow::BinaryType]::<lambda()> >(arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>::<lambda(int64_t)> &&,
> arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>::<lambda()> &&)
> (this=0x7ffc6aee8c70, visit_valid=..., visit_null=...) at
> /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:1222
> #4 0x00007f66dee4fd3e in arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>::GenerateOutput<arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>,
> arrow::BinaryType>::TakeAdapter<unsigned int> > (this=0x7ffc6aee8dd0) at
> /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:1535
> #5 0x00007f66dee45a4b in arrow::compute::internal::(anonymous
> namespace)::Selection<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType>, arrow::BinaryType>::ExecTake
> (this=0x7ffc6aee8dd0) at
> /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:1453
> #6 0x00007f66dee37241 in arrow::compute::internal::(anonymous
> namespace)::TakeExec<arrow::compute::internal::(anonymous
> namespace)::VarBinaryImpl<arrow::BinaryType> > (ctx=0x7ffc6aee91d0,
> batch=..., out=0x7ffc6aee9020) at
> /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:2324
> #7 0x00007f66de3843d8 in std::_Function_handler<arrow::Status
> (arrow::compute::KernelContext*, arrow::compute::ExecBatch const&,
> arrow::Datum*), arrow::Status (*)(arrow::compute::KernelContext*,
> arrow::compute::ExecBatch const&, arrow::Datum*)>::_M_invoke(std::_Any_data
> const&, arrow::compute::KernelContext*&&, arrow::compute::ExecBatch const&,
> arrow::Datum*&&) (__functor=..., __args#0=@0x7ffc6aee8f78: 0x7ffc6aee91d0,
> __args#1=..., __args#2=@0x7ffc6aee8f68: 0x7ffc6aee9020) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/std_function.h:286
> #8 0x00007f66de1b08cf in std::function<arrow::Status
> (arrow::compute::KernelContext*, arrow::compute::ExecBatch const&,
> arrow::Datum*)>::operator()(arrow::compute::KernelContext*,
> arrow::compute::ExecBatch const&, arrow::Datum*) const (this=0x562769ba2768,
> __args#0=0x7ffc6aee91d0, __args#1=..., __args#2=0x7ffc6aee9020) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/std_function.h:688
> #9 0x00007f66de1ad5d1 in arrow::compute::detail::(anonymous
> namespace)::VectorExecutor::ExecuteBatch (this=0x562769bdb400, batch=...,
> listener=0x7ffc6aee9260) at /arrow/cpp/src/arrow/compute/exec.cc:880
> #10 0x00007f66de1acfc6 in arrow::compute::detail::(anonymous
> namespace)::VectorExecutor::Execute (this=0x562769bdb400, args=...,
> listener=0x7ffc6aee9260) at /arrow/cpp/src/arrow/compute/exec.cc:846
> #11 0x00007f66de2cdab3 in arrow::compute::Function::Execute
> (this=0x562769ba19c0, args=..., options=0x7ffc6aee9aa0, ctx=0x7ffc6aee9800)
> at /arrow/cpp/src/arrow/compute/function.cc:248
> #12 0x00007f66de1af599 in arrow::compute::CallFunction (func_name=...,
> args=..., options=0x7ffc6aee9aa0, ctx=0x7ffc6aee9800) at
> /arrow/cpp/src/arrow/compute/exec.cc:1065
> #13 0x00007f66dee21dac in arrow::compute::internal::(anonymous
> namespace)::TakeAA (values=..., indices=..., options=..., ctx=0x7ffc6aee9800)
> at /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:1997
> #14 0x00007f66dee23e81 in arrow::compute::internal::(anonymous
> namespace)::TakeMetaFunction::ExecuteImpl (this=0x562769ba30f0, args=...,
> options=0x7ffc6aee9aa0, ctx=0x7ffc6aee9800) at
> /arrow/cpp/src/arrow/compute/kernels/vector_selection.cc:2128
> #15 0x00007f66de2cf3c9 in arrow::compute::MetaFunction::Execute
> (this=0x562769ba30f0, args=..., options=0x7ffc6aee9aa0, ctx=0x7ffc6aee9800)
> at /arrow/cpp/src/arrow/compute/function.cc:382
> #16 0x00007f66de1af599 in arrow::compute::CallFunction (func_name=...,
> args=..., options=0x7ffc6aee9aa0, ctx=0x7ffc6aee9800) at
> /arrow/cpp/src/arrow/compute/exec.cc:1065
> #17 0x00007f66de1af3fe in arrow::compute::CallFunction (func_name=...,
> args=..., options=0x7ffc6aee9aa0, ctx=0x0) at
> /arrow/cpp/src/arrow/compute/exec.cc:1061
> #18 0x00007f66de17af3d in arrow::compute::Take (values=..., filter=...,
> options=..., ctx=0x0) at /arrow/cpp/src/arrow/compute/api_vector.cc:305
> #19 0x00005627694e0ae5 in arrow::compute::TakeUsingVector
> (ctx=0x562769c04260, input=..., indices=..., result=0x7ffc6aee9c60) at
> /arrow/cpp/src/arrow/compute/exec/hash_join_node_test.cc:456
> #20 0x00005627694e2e1e in arrow::compute::GenRandomJoinTables
> (ctx=0x562769c04260, rng=..., num_rows_l=1140, num_rows_r=973,
> num_keys_common=263, num_keys_left=341, num_keys_right=401, key_types=...,
> payload_left_types=..., payload_right_types=..., key_id_l=0x7ffc6aeea090,
> key_id_r=0x7ffc6aeea0a8, left=0x7ffc6aeea0c0, right=0x7ffc6aeea0d8) at
> /arrow/cpp/src/arrow/compute/exec/hash_join_node_test.cc:615
> #21 0x00005627694e7c72 in arrow::compute::HashJoin_Random_Test::TestBody
> (this=0x562769afb1b0) at
> /arrow/cpp/src/arrow/compute/exec/hash_join_node_test.cc:1032
> #22 0x00007f66e0598c9c in
> testing::internal::HandleSehExceptionsInMethodIfSupported<testing::Test,
> void> (object=0x562769afb1b0, method=&virtual testing::Test::TestBody(),
> location=0x7f66e05ad97b "the test body") at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:2607
> #23 0x00007f66e058fdd2 in
> testing::internal::HandleExceptionsInMethodIfSupported<testing::Test, void>
> (object=0x562769afb1b0, method=&virtual testing::Test::TestBody(),
> location=0x7f66e05ad97b "the test body") at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:2643
> #24 0x00007f66e056ac03 in testing::Test::Run (this=0x562769afb1b0) at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:2682
> #25 0x00007f66e056b63b in testing::TestInfo::Run (this=0x562769af7a00) at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:2861
> #26 0x00007f66e056c010 in testing::TestSuite::Run (this=0x562769af7b20) at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:3015
> #27 0x00007f66e057c31c in testing::internal::UnitTestImpl::RunAllTests
> (this=0x562769af7190) at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:5855
> #28 0x00007f66e0599ce8 in
> testing::internal::HandleSehExceptionsInMethodIfSupported<testing::internal::UnitTestImpl,
> bool> (object=0x562769af7190, method=(bool
> (testing::internal::UnitTestImpl::*)(testing::internal::UnitTestImpl *
> const)) 0x7f66e057bed8 <testing::internal::UnitTestImpl::RunAllTests()>,
> location=0x7f66e05ae468 "auxiliary test code (environments or event
> listeners)") at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:2607
> #29 0x00007f66e0591064 in
> testing::internal::HandleExceptionsInMethodIfSupported<testing::internal::UnitTestImpl,
> bool> (object=0x562769af7190, method=(bool
> (testing::internal::UnitTestImpl::*)(testing::internal::UnitTestImpl *
> const)) 0x7f66e057bed8 <testing::internal::UnitTestImpl::RunAllTests()>,
> location=0x7f66e05ae468 "auxiliary test code (environments or event
> listeners)") at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:2643
> #30 0x00007f66e057a7b7 in testing::UnitTest::Run (this=0x7f66e05da260
> <testing::UnitTest::GetInstance()::instance>) at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest.cc:5438
> #31 0x00007f66e05db919 in RUN_ALL_TESTS () at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/include/gtest/gtest.h:2490
> #32 0x00007f66e05db95c in main (argc=1, argv=0x7ffc6aeea8a8) at
> /build/cpp/googletest_ep-prefix/src/googletest_ep/googletest/src/gtest_main.cc:52
> #33 0x00007f66dc6bcbf7 in __libc_start_main (main=0x7f66e05db91b <main(int,
> char**)>, argc=1, argv=0x7ffc6aeea8a8, init=<optimized out>, fini=<optimized
> out>, rtld_fini=<optimized out>, stack_end=0x7ffc6aeea898) at
> ../csu/libc-start.c:310
> #34 0x00005627694d4f29 in _start ()
> Thread 4 (Thread 0x7f66d65ff700 (LWP 20462)):
> #0 0x00007f66dc0ec065 in futex_abstimed_wait_cancelable (private=<optimized
> out>, abstime=0x7f66d65fd4a0, expected=0, futex_word=0x7f66da40a6c0) at
> ../sysdeps/unix/sysv/linux/futex-internal.h:205
> #1 __pthread_cond_wait_common (abstime=0x7f66d65fd4a0, mutex=0x7f66da40a708,
> cond=0x7f66da40a698) at pthread_cond_wait.c:539
> #2 __pthread_cond_timedwait (cond=0x7f66da40a698, mutex=0x7f66da40a708,
> abstime=0x7f66d65fd4a0) at pthread_cond_wait.c:667
> #3 0x00007f66df325f26 in background_thread_sleep (tsdn=<optimized out>,
> interval=<optimized out>, info=0x7f66da40a690) at src/background_thread.c:255
> #4 background_work_sleep_once (ind=<optimized out>, info=<optimized out>,
> tsdn=<optimized out>) at src/background_thread.c:307
> #5 background_work (ind=<optimized out>, tsd=<optimized out>) at
> src/background_thread.c:497
> #6 background_thread_entry () at src/background_thread.c:522
> #7 0x00007f66dc0e56db in start_thread (arg=0x7f66d65ff700) at
> pthread_create.c:463
> #8 0x00007f66dc7bc71f in clone () at
> ../sysdeps/unix/sysv/linux/x86_64/clone.S:95
> Thread 3 (Thread 0x7f66d8b7e700 (LWP 20460)):
> #0 0x00007f66dc0ebad3 in futex_wait_cancelable (private=<optimized out>,
> expected=0, futex_word=0x562769be4780) at
> ../sysdeps/unix/sysv/linux/futex-internal.h:88
> #1 __pthread_cond_wait_common (abstime=0x0, mutex=0x562769be4730,
> cond=0x562769be4758) at pthread_cond_wait.c:502
> #2 __pthread_cond_wait (cond=0x562769be4758, mutex=0x562769be4730) at
> pthread_cond_wait.c:655
> #3 0x00007f66dcb544d1 in __gthread_cond_wait (__mutex=<error reading
> variable: dwarf2_find_location_expression: Corrupted DWARF expression.>,
> __cond=<optimized out>) at
> /home/conda/feedstock_root/build_artifacts/gcc_compilers_1634095553113/work/build/x86_64-conda-linux-gnu/libstdc++-v3/src/c++11/condition_variable.cc:865
> #4 std::__condvar::wait (__m=<error reading variable:
> dwarf2_find_location_expression: Corrupted DWARF expression.>,
> this=<optimized out>) at
> ../../../../../libstdc++-v3/src/c++11/gthr-default.h:155
> #5 std::condition_variable::wait (this=<optimized out>, __lock=...) at
> ../../../../../libstdc++-v3/src/c++11/condition_variable.cc:41
> #6 0x00007f66ddf376af in arrow::internal::WorkerLoop (state=..., it=...) at
> /arrow/cpp/src/arrow/util/thread_pool.cc:195
> #7 0x00007f66ddf38458 in
> arrow::internal::ThreadPool::<lambda()>::operator()(void) const
> (__closure=0x562769cd8b98) at /arrow/cpp/src/arrow/util/thread_pool.cc:344
> #8 0x00007f66ddf3ef90 in std::__invoke_impl<void,
> arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> >(std::__invoke_other, arrow::internal::ThreadPool::<lambda()> &&) (__f=...)
> at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/invoke.h:60
> #9 0x00007f66ddf3ef30 in
> std::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> >(arrow::internal::ThreadPool::<lambda()> &&) (__fn=...) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/invoke.h:95
> #10 0x00007f66ddf3eece in
> std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > >::_M_invoke<0>(std::_Index_tuple<0>) (this=0x562769cd8b98) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/thread:244
> #11 0x00007f66ddf3ed8b in
> std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > >::operator()(void) (this=0x562769cd8b98) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/thread:251
> #12 0x00007f66ddf3ecdc in
> std::thread::_State_impl<std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > > >::_M_run(void) (this=0x562769cd8b90) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/thread:195
> #13 0x00007f66dcb589d4 in std::execute_native_thread_routine (__p=<optimized
> out>) at
> /home/conda/feedstock_root/build_artifacts/gcc_compilers_1634095553113/work/build/x86_64-conda-linux-gnu/libstdc++-v3/include/bits/new_allocator.h:82
> #14 0x00007f66dc0e56db in start_thread (arg=0x7f66d8b7e700) at
> pthread_create.c:463
> #15 0x00007f66dc7bc71f in clone () at
> ../sysdeps/unix/sysv/linux/x86_64/clone.S:95
> Thread 2 (Thread 0x7f66d9dff700 (LWP 20459)):
> #0 0x00007f66dc0ec065 in futex_abstimed_wait_cancelable (private=<optimized
> out>, abstime=0x7f66d9dfd4a0, expected=0, futex_word=0x7f66da40a5f4) at
> ../sysdeps/unix/sysv/linux/futex-internal.h:205
> #1 __pthread_cond_wait_common (abstime=0x7f66d9dfd4a0, mutex=0x7f66da40a638,
> cond=0x7f66da40a5c8) at pthread_cond_wait.c:539
> #2 __pthread_cond_timedwait (cond=0x7f66da40a5c8, mutex=0x7f66da40a638,
> abstime=0x7f66d9dfd4a0) at pthread_cond_wait.c:667
> #3 0x00007f66df326656 in background_thread_sleep (tsdn=<optimized out>,
> interval=<optimized out>, info=<optimized out>) at src/background_thread.c:255
> #4 background_work_sleep_once (ind=0, info=<optimized out>, tsdn=<optimized
> out>) at src/background_thread.c:307
> #5 background_thread0_work (tsd=<optimized out>) at
> src/background_thread.c:452
> #6 background_work (ind=<optimized out>, tsd=<optimized out>) at
> src/background_thread.c:490
> #7 background_thread_entry () at src/background_thread.c:522
> #8 0x00007f66dc0e56db in start_thread (arg=0x7f66d9dff700) at
> pthread_create.c:463
> #9 0x00007f66dc7bc71f in clone () at
> ../sysdeps/unix/sysv/linux/x86_64/clone.S:95
> Thread 1 (Thread 0x7f66d7b7d700 (LWP 20461)):
> #0 0x00000000000117bb in ?? ()
> #1 0x00007f66de2c3083 in arrow::compute::TaskSchedulerImpl::ScheduleMore
> (this=0x7f66c801ee20, thread_id=0, num_tasks_finished=0) at
> /arrow/cpp/src/arrow/compute/exec/task_util.cc:326
> #2 0x00007f66de2c1eec in arrow::compute::TaskSchedulerImpl::StartTaskGroup
> (this=0x7f66c801ee20, thread_id=0, group_id=1, total_num_tasks=0) at
> /arrow/cpp/src/arrow/compute/exec/task_util.cc:153
> #3 0x00007f66de2213b4 in
> arrow::compute::HashJoinBasicImpl::ProbeQueuedBatches (this=0x7f66d004acb0,
> thread_index=0) at /arrow/cpp/src/arrow/compute/exec/hash_join.cc:716
> #4 0x00007f66de220b9d in
> arrow::compute::HashJoinBasicImpl::BuildHashTable_on_finished
> (this=0x7f66d004acb0, thread_index=0) at
> /arrow/cpp/src/arrow/compute/exec/hash_join.cc:653
> #5 0x00007f66de220d3d in
> arrow::compute::HashJoinBasicImpl::RegisterBuildHashTable()::{lambda(unsigned
> long)#2}::operator()(unsigned long) const (__closure=0x562769d5d7c0,
> thread_index=0) at /arrow/cpp/src/arrow/compute/exec/hash_join.cc:664
> #6 0x00007f66de225b76 in std::_Function_handler<arrow::Status (unsigned
> long),
> arrow::compute::HashJoinBasicImpl::RegisterBuildHashTable()::{lambda(unsigned
> long)#2}>::_M_invoke(std::_Any_data const&, unsigned long&&) (__functor=...,
> __args#0=@0x7f66d7b7b138: 0) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/std_function.h:286
> #7 0x00007f66de24e28a in std::function<arrow::Status (unsigned
> long)>::operator()(unsigned long) const (this=0x562769d5d7c0, __args#0=0) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/std_function.h:688
> #8 0x00007f66de2c25e1 in
> arrow::compute::TaskSchedulerImpl::OnTaskGroupFinished (this=0x7f66c801ee20,
> thread_id=0, group_id=0, all_task_groups_finished=0x7f66d7b7b230) at
> /arrow/cpp/src/arrow/compute/exec/task_util.cc:244
> #9 0x00007f66de2c2ed4 in
> arrow::compute::TaskSchedulerImpl::<lambda(size_t)>::operator()(size_t) const
> (__closure=0x562769bdb540, thread_id=0) at
> /arrow/cpp/src/arrow/compute/exec/task_util.cc:349
> #10 0x00007f66de2c4acf in std::_Function_handler<arrow::Status(long unsigned
> int), arrow::compute::TaskSchedulerImpl::ScheduleMore(size_t,
> int)::<lambda(size_t)> >::_M_invoke(const std::_Any_data &, unsigned long &&)
> (__functor=..., __args#0=@0x7f66d7b7b2b8: 0) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/std_function.h:286
> #11 0x00007f66de24e28a in std::function<arrow::Status (unsigned
> long)>::operator()(unsigned long) const (this=0x562769d65ed0, __args#0=0) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/std_function.h:688
> #12 0x00007f66de24b9f8 in
> arrow::compute::HashJoinNode::ScheduleTaskCallback(std::function<arrow::Status
> (unsigned long)>)::{lambda()#1}::operator()() const
> (__closure=0x562769d65ec8) at
> /arrow/cpp/src/arrow/compute/exec/hash_join_node.cc:590
> #13 0x00007f66de25cda7 in arrow::internal::FnOnce<void
> ()>::FnImpl<arrow::compute::HashJoinNode::ScheduleTaskCallback(std::function<arrow::Status
> (unsigned long)>)::{lambda()#1}>::invoke() (this=0x562769d65ec0) at
> /arrow/cpp/src/arrow/util/functional.h:152
> #14 0x00007f66ddf395d6 in arrow::internal::FnOnce<void ()>::operator()() &&
> (this=0x7f66d7b7b3f0) at /arrow/cpp/src/arrow/util/functional.h:140
> #15 0x00007f66ddf3757f in arrow::internal::WorkerLoop (state=..., it=...) at
> /arrow/cpp/src/arrow/util/thread_pool.cc:177
> #16 0x00007f66ddf38458 in
> arrow::internal::ThreadPool::<lambda()>::operator()(void) const
> (__closure=0x562769c445b8) at /arrow/cpp/src/arrow/util/thread_pool.cc:344
> #17 0x00007f66ddf3ef90 in std::__invoke_impl<void,
> arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> >(std::__invoke_other, arrow::internal::ThreadPool::<lambda()> &&) (__f=...)
> at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/invoke.h:60
> #18 0x00007f66ddf3ef30 in
> std::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> >(arrow::internal::ThreadPool::<lambda()> &&) (__fn=...) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/bits/invoke.h:95
> #19 0x00007f66ddf3eece in
> std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > >::_M_invoke<0>(std::_Index_tuple<0>) (this=0x562769c445b8) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/thread:244
> #20 0x00007f66ddf3ed8b in
> std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > >::operator()(void) (this=0x562769c445b8) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/thread:251
> #21 0x00007f66ddf3ecdc in
> std::thread::_State_impl<std::thread::_Invoker<std::tuple<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::<lambda()>
> > > >::_M_run(void) (this=0x562769c445b0) at
> /opt/conda/envs/arrow/x86_64-conda-linux-gnu/include/c++/9.4.0/thread:195
> #22 0x00007f66dcb589d4 in std::execute_native_thread_routine (__p=<optimized
> out>) at
> /home/conda/feedstock_root/build_artifacts/gcc_compilers_1634095553113/work/build/x86_64-conda-linux-gnu/libstdc++-v3/include/bits/new_allocator.h:82
> #23 0x00007f66dc0e56db in start_thread (arg=0x7f66d7b7d700) at
> pthread_create.c:463
> #24 0x00007f66dc7bc71f in clone () at
> ../sysdeps/unix/sysv/linux/x86_64/clone.S:95
> /build/cpp/src/arrow/compute/exec
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
