[R] head() is crashing on some nightly builds

[asfimport]

A few examples:

• https://github.com/ursacomputing/crossbow/actions/runs/3368026889/jobs/5586109693#step:10:3813

• https://github.com/ursacomputing/crossbow/actions/runs/3368024633/jobs/5586105172#step:9:3813

  I suspect this is because the HeadRecordBatchReader is resetting the shared_ptr to its parent...in ARROW-18174 we discovered that this was causing crashes in some places.

Reporter: Dewey Dunnington / @paleolimbot
Assignee: Dewey Dunnington / @paleolimbot

Original Issue Attachments:

• Screen Shot 2022-11-25 at 3.39.44 PM.png
• Screen Shot 2022-11-25 at 3.40.54 PM.png

PRs and other links:

• GitHub Pull Request #14582

_{Note: This issue was originally created as ARROW-18240. Please see the migration documentation for further details.}

[asfimport]

Dewey Dunnington / @paleolimbot:
Ok, I finally have a reproducer for this. I don't think the problems is MacOS...I think the problem is that the MacOS runners only have 1 CPU available for Arrow. Setting set_cpu_count() locally to 1, I can reproduce a deadlock in a simple head() call after a filter().

library(arrow, warn.conflicts = FALSE)
#> Some features are not enabled in this build of Arrow. Run `arrow_info()` for more information.

dataset_dir <- tempfile()
write_dataset(mtcars, dataset_dir, )

# change to set_cpu_count(1) to reproduce the deadlock
set_cpu_count(2)

open_dataset(dataset_dir) |> 
 dplyr::filter(mpg > 30) |> 
 head() |> 
 dplyr::collect()
#> mpg cyl disp hp drat wt qsec vs am gear carb
#> 1 32.4 4 78.7 66 4.08 2.200 19.47 1 1 4 1
#> 2 30.4 4 75.7 52 4.93 1.615 18.52 1 1 4 2
#> 3 33.9 4 71.1 65 4.22 1.835 19.90 1 1 4 1
#> 4 30.4 4 95.1 113 3.77 1.513 16.90 1 1 5 2

[asfimport]

Dewey Dunnington / @paleolimbot:
A low-tech output of where this deadlock occurs is attached above as photos. The verbose backtrace of the deadlock is:

Console is in 'commands' mode, prefix expressions with '?'.
Attached to process 41399
Stop reason: signal SIGSTOP
bt
* thread #1, queue = 'com.apple.main-thread', stop reason = signal SIGSTOP
 * frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x0000000158803e6c libarrow.1100.0.0.dylib`void std::__1::condition_variable::wait<arrow::internal::SerialExecutor::RunLoop()::$_0>(this=0x0000600002dcd048, __lk=0x000000016d696e68, __pred=(0x000000016d696ed8))::$_0) at __mutex_base:404:9
 frame #4: 0x00000001588034c0 libarrow.1100.0.0.dylib`arrow::internal::SerialExecutor::RunLoop(this=0x000000016d696ed8) at thread_pool.cc:174:28
 frame #5: 0x0000000105a39c64 arrow.so`arrow::Future<std::__1::shared_ptr<arrow::Table>> arrow::internal::SerialExecutor::Run<std::__1::shared_ptr<arrow::Table>, arrow::Result<std::__1::shared_ptr<arrow::Table>>>(this=0x000000016d696ed8, initial_task=arrow::internal::SerialExecutor::TopLevelTask<std::__1::shared_ptr<arrow::Table> > @ 0x000000016d696ed0)>) at thread_pool.h:392:5 [opt]
 frame #6: 0x0000000105a3983c arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> arrow::internal::SerialExecutor::RunInSerialExecutor<std::__1::shared_ptr<arrow::Table>, arrow::Future<std::__1::shared_ptr<arrow::Table>>, arrow::Result<std::__1::shared_ptr<arrow::Table>>>(initial_task=arrow::internal::SerialExecutor::TopLevelTask<std::__1::shared_ptr<arrow::Table> > @ 0x000000016d696f30)>) at thread_pool.h:289:38 [opt]
 frame #7: 0x0000000105a395e4 arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> RunWithCapturedR<std::__1::shared_ptr<arrow::Table>>(make_arrow_call=function<arrow::Future<std::__1::shared_ptr<arrow::Table> > ()> @ 0x000000016d696fc8)>) at safe-call-into-r.h:287:29 [opt]
 frame #8: 0x0000000105a2a29c arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> RunWithCapturedRIfPossible<std::__1::shared_ptr<arrow::Table>>(make_arrow_call=function<arrow::Result<std::__1::shared_ptr<arrow::Table> > ()> @ 0x000000016d697020)>) at safe-call-into-r.h:314:12 [opt]
 frame #9: 0x0000000105a2a144 arrow.so`Table__from_ExecPlanReader(reader=<unavailable>) at compute-exec.cpp:195:17 [opt]
 frame #10: 0x00000001059d9668 arrow.so`::_arrow_Table__from_ExecPlanReader(reader_sexp=<unavailable>) at arrowExports.cpp:927:24 [opt]
 frame #11: 0x0000000102fd1be4 libR.dylib`R_doDotCall(ofun=<unavailable>, nargs=<unavailable>, cargs=<unavailable>, call=0x000000011f788dd8) at dotcode.c:601:17 [opt]
 frame #12: 0x000000010301a2dc libR.dylib`bcEval(body=0x000000011f786320, rho=<unavailable>, useCache=<unavailable>) at eval.c:7692:21 [opt]
 frame #13: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f786320, rho=0x000000011f788710) at eval.c:748:8 [opt]
 frame #14: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011ed54250, newrho=0x000000011f788710, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #15: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011ed54250, op=0x000000011f786ba8, arglist=0x000000011f788780, rho=0x000000011f786cf8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #16: 0x000000010300085c libR.dylib`Rf_eval(e=0x000000011ed54250, rho=0x000000011f786cf8) at eval.c:871:12 [opt]
 frame #17: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f787b68, newrho=0x000000011f786cf8, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #18: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f787b68, op=0x000000011f75fa50, arglist=0x000000014d00c0e0, rho=0x000000011f786f28, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #19: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f7853f8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #20: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f7853f8, rho=0x000000011f786f28) at eval.c:748:8 [opt]
 frame #21: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f786fd0, newrho=0x000000011f786f28, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #22: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f786fd0, op=0x000000011f785fc8, arglist=0x000000011e00e070, rho=0x000000011e00df90, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #23: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #24: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000014f57ad00, sxp=0x000000011f785fc8, dotClass=0x00000001286427e8, cptr=0x000000016d69be00, method=0x000000014dd012e0, generic=<unavailable>, rho=0x000000011e00df90, callrho=<unavailable>, defrho=0x000000014dc50180) at objects.c:436:16 [opt]
 frame #25: 0x0000000103069088 libR.dylib`Rf_usemethod(generic="as_arrow_table", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000011e00df90, callrho=0x000000011e00e0e0, defrho=0x000000014dc50180, ans=0x000000016d69b4c0) at objects.c:472:10 [opt]
 frame #26: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000014f576248, op=<unavailable>, args=<unavailable>, env=0x000000011e00df90) at objects.c:565:9 [opt]
 frame #27: 0x0000000103008170 libR.dylib`bcEval(body=0x000000014f578bb0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #28: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f578bb0, rho=0x000000011e00df90) at eval.c:748:8 [opt]
 frame #29: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011e009970, newrho=0x000000011e00df90, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #30: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011e009970, op=0x000000014f57ad00, arglist=0x000000011e00e070, rho=0x000000011e00e0e0, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #31: 0x0000000103007770 libR.dylib`bcEval(body=0x000000012e7fbff8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #32: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000012e7fbff8, rho=0x000000011e00e0e0) at eval.c:748:8 [opt]
 frame #33: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011e00a278, newrho=0x000000011e00e0e0, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #34: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011e00a278, op=0x000000012e7f8fc8, arglist=0x000000012e7f92a0, rho=0x000000012e7f91c0, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #35: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #36: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000014f57ad00, sxp=0x000000012e7f8fc8, dotClass=0x000000012f7d7238, cptr=0x000000016d69daa0, method=0x000000014dd01eb0, generic=<unavailable>, rho=0x000000012e7f91c0, callrho=<unavailable>, defrho=0x000000014dc50180) at objects.c:436:16 [opt]
 frame #37: 0x0000000103069180 libR.dylib`Rf_usemethod(generic="as_arrow_table", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000012e7f91c0, callrho=0x000000012e7f6a78, defrho=0x000000014dc50180, ans=0x000000016d69d160) at objects.c:0 [opt]
 frame #38: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000014f576248, op=<unavailable>, args=<unavailable>, env=0x000000012e7f91c0) at objects.c:565:9 [opt]
 frame #39: 0x0000000103008170 libR.dylib`bcEval(body=0x000000014f578bb0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #40: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f578bb0, rho=0x000000012e7f91c0) at eval.c:748:8 [opt]
 frame #41: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f8bc400, newrho=0x000000012e7f91c0, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #42: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f8bc400, op=0x000000014f57ad00, arglist=0x000000012e7f92a0, rho=0x000000012e7f6a78, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #43: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f8be208, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #44: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f8be208, rho=0x000000012e7f6a78) at eval.c:748:8 [opt]
 frame #45: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f6a40) at eval.c:568:8 [opt]
 frame #46: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f6a40, symbol=0x000000014d05e750, rho=0x000000012e7f6880, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #47: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f6880, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #48: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f192c18, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #49: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f192c18, rho=0x000000012e7f6880) at eval.c:748:8 [opt]
 frame #50: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f63e8) at eval.c:568:8 [opt]
 frame #51: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f63e8, symbol=0x000000014d05e750, rho=0x000000012e7fa110, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #52: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7fa110, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #53: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f190a78, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #54: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f190a78, rho=0x000000012e7fa110) at eval.c:748:8 [opt]
 frame #55: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7fa068) at eval.c:568:8 [opt]
 frame #56: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7fa068, symbol=0x000000014d05e750, rho=0x000000012e7f9dc8, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #57: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f9dc8, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #58: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f192f60, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #59: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f192f60, rho=0x000000012e7f9dc8) at eval.c:748:8 [opt]
 frame #60: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f9d20) at eval.c:568:8 [opt]
 frame #61: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f9d20, symbol=0x000000014d05e750, rho=0x000000012e7f9700, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #62: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f9700, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #63: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f1932e0, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #64: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f1932e0, rho=0x000000012e7f9700) at eval.c:748:8 [opt]
 frame #65: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f1900a0, newrho=0x000000012e7f9700, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #66: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f1900a0, op=0x000000012e7f9d90, arglist=0x000000012e7f9968, rho=0x000000012e7f9dc8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #67: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f1907a0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #68: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f1907a0, rho=0x000000012e7f9dc8) at eval.c:748:8 [opt]
 frame #69: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f18d0e0, newrho=0x000000012e7f9dc8, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #70: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f18d0e0, op=0x000000012e7f67d8, arglist=0x000000012e7fa030, rho=0x000000012e7fa110, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #71: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f18db60, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #72: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f18db60, rho=0x000000012e7fa110) at eval.c:748:8 [opt]
 frame #73: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f18dd58, newrho=0x000000012e7fa110, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #74: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f18dd58, op=0x000000012e7f6848, arglist=0x000000012e7f63b0, rho=0x000000012e7f6880, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #75: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f17aec8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #76: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f17aec8, rho=0x000000012e7f6880) at eval.c:748:8 [opt]
 frame #77: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f8bc470, newrho=0x000000012e7f6880, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #78: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f8bc470, op=0x000000014f17b018, arglist=0x000000012e7f6a08, rho=0x000000012e7f6a78, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #79: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f8bd890, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #80: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f8bd890, rho=0x000000012e7f6a78) at eval.c:748:8 [opt]
 frame #81: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f745c48, newrho=0x000000012e7f6a78, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #82: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f745c48, op=0x000000011f8ba240, arglist=0x000000012e7c10e0, rho=0x000000012e7c1188, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #83: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f7436d0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #84: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f7436d0, rho=0x000000012e7c1188) at eval.c:748:8 [opt]
 frame #85: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000012e7c1268, newrho=0x000000012e7c1188, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #86: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000012e7c1268, op=0x000000011f743fc8, arglist=0x000000011eedc938, rho=0x000000011eedc890, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #87: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #88: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000012822fa60, sxp=0x000000011f743fc8, dotClass=0x000000012f7d7238, cptr=0x000000016d6a5450, method=0x000000014dc4de20, generic=<unavailable>, rho=0x000000011eedc890, callrho=<unavailable>, defrho=0x000000012ebade50) at objects.c:436:16 [opt]
 frame #89: 0x0000000103069180 libR.dylib`Rf_usemethod(generic="collect", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000011eedc890, callrho=0x000000014d047cc8, defrho=0x000000012ebade50, ans=0x000000016d6a4b10) at objects.c:0 [opt]
 frame #90: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000012822f600, op=<unavailable>, args=<unavailable>, env=0x000000011eedc890) at objects.c:565:9 [opt]
 frame #91: 0x0000000103008170 libR.dylib`bcEval(body=0x000000012822f6a8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #92: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000012822f6a8, rho=0x000000011eedc890) at eval.c:748:8 [opt]
 frame #93: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011eedcb30, newrho=0x000000011eedc890, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #94: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011eedcb30, op=0x000000012822fa60, arglist=0x000000011eedc938, rho=0x000000014d047cc8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #95: 0x000000010300085c libR.dylib`Rf_eval(e=0x000000011eedcb30, rho=0x000000014d047cc8) at eval.c:871:12 [opt]
 frame #96: 0x0000000103052d7c libR.dylib`Rf_ReplIteration(rho=0x000000014d047cc8, savestack=<unavailable>, browselevel=<unavailable>, state=0x000000016d6a59b0) at main.c:264:2 [opt]
 frame #97: 0x00000001030542ac libR.dylib`R_ReplConsole(rho=0x000000014d047cc8, savestack=0, browselevel=0) at main.c:316:11 [opt]
 frame #98: 0x00000001030541e4 libR.dylib`run_Rmainloop at main.c:1137:5 [opt]
 frame #99: 0x0000000103054390 libR.dylib`Rf_mainloop at main.c:1144:5 [opt]
 frame #100: 0x000000010275bea0 R`main + 32
 frame #101: 0x0000000102acd08c dyld`start + 520

bt
* thread #1, queue = 'com.apple.main-thread', stop reason = signal SIGSTOP
 * frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x0000000158803e6c libarrow.1100.0.0.dylib`void std::__1::condition_variable::wait<arrow::internal::SerialExecutor::RunLoop()::$_0>(this=0x0000600002dcd048, __lk=0x000000016d696e68, __pred=(0x000000016d696ed8))::$_0) at __mutex_base:404:9
 frame #4: 0x00000001588034c0 libarrow.1100.0.0.dylib`arrow::internal::SerialExecutor::RunLoop(this=0x000000016d696ed8) at thread_pool.cc:174:28
 frame #5: 0x0000000105a39c64 arrow.so`arrow::Future<std::__1::shared_ptr<arrow::Table>> arrow::internal::SerialExecutor::Run<std::__1::shared_ptr<arrow::Table>, arrow::Result<std::__1::shared_ptr<arrow::Table>>>(this=0x000000016d696ed8, initial_task=arrow::internal::SerialExecutor::TopLevelTask<std::__1::shared_ptr<arrow::Table> > @ 0x000000016d696ed0)>) at thread_pool.h:392:5 [opt]
 frame #6: 0x0000000105a3983c arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> arrow::internal::SerialExecutor::RunInSerialExecutor<std::__1::shared_ptr<arrow::Table>, arrow::Future<std::__1::shared_ptr<arrow::Table>>, arrow::Result<std::__1::shared_ptr<arrow::Table>>>(initial_task=arrow::internal::SerialExecutor::TopLevelTask<std::__1::shared_ptr<arrow::Table> > @ 0x000000016d696f30)>) at thread_pool.h:289:38 [opt]
 frame #7: 0x0000000105a395e4 arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> RunWithCapturedR<std::__1::shared_ptr<arrow::Table>>(make_arrow_call=function<arrow::Future<std::__1::shared_ptr<arrow::Table> > ()> @ 0x000000016d696fc8)>) at safe-call-into-r.h:287:29 [opt]
 frame #8: 0x0000000105a2a29c arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> RunWithCapturedRIfPossible<std::__1::shared_ptr<arrow::Table>>(make_arrow_call=function<arrow::Result<std::__1::shared_ptr<arrow::Table> > ()> @ 0x000000016d697020)>) at safe-call-into-r.h:314:12 [opt]
 frame #9: 0x0000000105a2a144 arrow.so`Table__from_ExecPlanReader(reader=<unavailable>) at compute-exec.cpp:195:17 [opt]
 frame #10: 0x00000001059d9668 arrow.so`::_arrow_Table__from_ExecPlanReader(reader_sexp=<unavailable>) at arrowExports.cpp:927:24 [opt]
 frame #11: 0x0000000102fd1be4 libR.dylib`R_doDotCall(ofun=<unavailable>, nargs=<unavailable>, cargs=<unavailable>, call=0x000000011f788dd8) at dotcode.c:601:17 [opt]
 frame #12: 0x000000010301a2dc libR.dylib`bcEval(body=0x000000011f786320, rho=<unavailable>, useCache=<unavailable>) at eval.c:7692:21 [opt]
 frame #13: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f786320, rho=0x000000011f788710) at eval.c:748:8 [opt]
 frame #14: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011ed54250, newrho=0x000000011f788710, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #15: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011ed54250, op=0x000000011f786ba8, arglist=0x000000011f788780, rho=0x000000011f786cf8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #16: 0x000000010300085c libR.dylib`Rf_eval(e=0x000000011ed54250, rho=0x000000011f786cf8) at eval.c:871:12 [opt]
 frame #17: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f787b68, newrho=0x000000011f786cf8, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #18: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f787b68, op=0x000000011f75fa50, arglist=0x000000014d00c0e0, rho=0x000000011f786f28, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #19: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f7853f8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #20: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f7853f8, rho=0x000000011f786f28) at eval.c:748:8 [opt]
 frame #21: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f786fd0, newrho=0x000000011f786f28, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #22: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f786fd0, op=0x000000011f785fc8, arglist=0x000000011e00e070, rho=0x000000011e00df90, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #23: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #24: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000014f57ad00, sxp=0x000000011f785fc8, dotClass=0x00000001286427e8, cptr=0x000000016d69be00, method=0x000000014dd012e0, generic=<unavailable>, rho=0x000000011e00df90, callrho=<unavailable>, defrho=0x000000014dc50180) at objects.c:436:16 [opt]
 frame #25: 0x0000000103069088 libR.dylib`Rf_usemethod(generic="as_arrow_table", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000011e00df90, callrho=0x000000011e00e0e0, defrho=0x000000014dc50180, ans=0x000000016d69b4c0) at objects.c:472:10 [opt]
 frame #26: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000014f576248, op=<unavailable>, args=<unavailable>, env=0x000000011e00df90) at objects.c:565:9 [opt]
 frame #27: 0x0000000103008170 libR.dylib`bcEval(body=0x000000014f578bb0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #28: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f578bb0, rho=0x000000011e00df90) at eval.c:748:8 [opt]
 frame #29: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011e009970, newrho=0x000000011e00df90, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #30: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011e009970, op=0x000000014f57ad00, arglist=0x000000011e00e070, rho=0x000000011e00e0e0, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #31: 0x0000000103007770 libR.dylib`bcEval(body=0x000000012e7fbff8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #32: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000012e7fbff8, rho=0x000000011e00e0e0) at eval.c:748:8 [opt]
 frame #33: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011e00a278, newrho=0x000000011e00e0e0, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #34: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011e00a278, op=0x000000012e7f8fc8, arglist=0x000000012e7f92a0, rho=0x000000012e7f91c0, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #35: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #36: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000014f57ad00, sxp=0x000000012e7f8fc8, dotClass=0x000000012f7d7238, cptr=0x000000016d69daa0, method=0x000000014dd01eb0, generic=<unavailable>, rho=0x000000012e7f91c0, callrho=<unavailable>, defrho=0x000000014dc50180) at objects.c:436:16 [opt]
 frame #37: 0x0000000103069180 libR.dylib`Rf_usemethod(generic="as_arrow_table", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000012e7f91c0, callrho=0x000000012e7f6a78, defrho=0x000000014dc50180, ans=0x000000016d69d160) at objects.c:0 [opt]
 frame #38: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000014f576248, op=<unavailable>, args=<unavailable>, env=0x000000012e7f91c0) at objects.c:565:9 [opt]
 frame #39: 0x0000000103008170 libR.dylib`bcEval(body=0x000000014f578bb0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #40: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f578bb0, rho=0x000000012e7f91c0) at eval.c:748:8 [opt]
 frame #41: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f8bc400, newrho=0x000000012e7f91c0, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #42: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f8bc400, op=0x000000014f57ad00, arglist=0x000000012e7f92a0, rho=0x000000012e7f6a78, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #43: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f8be208, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #44: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f8be208, rho=0x000000012e7f6a78) at eval.c:748:8 [opt]
 frame #45: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f6a40) at eval.c:568:8 [opt]
 frame #46: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f6a40, symbol=0x000000014d05e750, rho=0x000000012e7f6880, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #47: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f6880, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #48: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f192c18, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #49: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f192c18, rho=0x000000012e7f6880) at eval.c:748:8 [opt]
 frame #50: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f63e8) at eval.c:568:8 [opt]
 frame #51: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f63e8, symbol=0x000000014d05e750, rho=0x000000012e7fa110, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #52: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7fa110, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #53: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f190a78, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #54: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f190a78, rho=0x000000012e7fa110) at eval.c:748:8 [opt]
 frame #55: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7fa068) at eval.c:568:8 [opt]
 frame #56: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7fa068, symbol=0x000000014d05e750, rho=0x000000012e7f9dc8, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #57: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f9dc8, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #58: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f192f60, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #59: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f192f60, rho=0x000000012e7f9dc8) at eval.c:748:8 [opt]
 frame #60: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f9d20) at eval.c:568:8 [opt]
 frame #61: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f9d20, symbol=0x000000014d05e750, rho=0x000000012e7f9700, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #62: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f9700, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #63: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f1932e0, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #64: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f1932e0, rho=0x000000012e7f9700) at eval.c:748:8 [opt]
 frame #65: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f1900a0, newrho=0x000000012e7f9700, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #66: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f1900a0, op=0x000000012e7f9d90, arglist=0x000000012e7f9968, rho=0x000000012e7f9dc8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #67: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f1907a0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #68: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f1907a0, rho=0x000000012e7f9dc8) at eval.c:748:8 [opt]
 frame #69: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f18d0e0, newrho=0x000000012e7f9dc8, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #70: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f18d0e0, op=0x000000012e7f67d8, arglist=0x000000012e7fa030, rho=0x000000012e7fa110, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #71: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f18db60, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #72: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f18db60, rho=0x000000012e7fa110) at eval.c:748:8 [opt]
 frame #73: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f18dd58, newrho=0x000000012e7fa110, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #74: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f18dd58, op=0x000000012e7f6848, arglist=0x000000012e7f63b0, rho=0x000000012e7f6880, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #75: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f17aec8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #76: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f17aec8, rho=0x000000012e7f6880) at eval.c:748:8 [opt]
 frame #77: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f8bc470, newrho=0x000000012e7f6880, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #78: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f8bc470, op=0x000000014f17b018, arglist=0x000000012e7f6a08, rho=0x000000012e7f6a78, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #79: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f8bd890, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #80: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f8bd890, rho=0x000000012e7f6a78) at eval.c:748:8 [opt]
 frame #81: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f745c48, newrho=0x000000012e7f6a78, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #82: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f745c48, op=0x000000011f8ba240, arglist=0x000000012e7c10e0, rho=0x000000012e7c1188, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #83: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f7436d0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #84: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f7436d0, rho=0x000000012e7c1188) at eval.c:748:8 [opt]
 frame #85: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000012e7c1268, newrho=0x000000012e7c1188, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #86: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000012e7c1268, op=0x000000011f743fc8, arglist=0x000000011eedc938, rho=0x000000011eedc890, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #87: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #88: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000012822fa60, sxp=0x000000011f743fc8, dotClass=0x000000012f7d7238, cptr=0x000000016d6a5450, method=0x000000014dc4de20, generic=<unavailable>, rho=0x000000011eedc890, callrho=<unavailable>, defrho=0x000000012ebade50) at objects.c:436:16 [opt]
 frame #89: 0x0000000103069180 libR.dylib`Rf_usemethod(generic="collect", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000011eedc890, callrho=0x000000014d047cc8, defrho=0x000000012ebade50, ans=0x000000016d6a4b10) at objects.c:0 [opt]
 frame #90: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000012822f600, op=<unavailable>, args=<unavailable>, env=0x000000011eedc890) at objects.c:565:9 [opt]
 frame #91: 0x0000000103008170 libR.dylib`bcEval(body=0x000000012822f6a8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #92: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000012822f6a8, rho=0x000000011eedc890) at eval.c:748:8 [opt]
 frame #93: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011eedcb30, newrho=0x000000011eedc890, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #94: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011eedcb30, op=0x000000012822fa60, arglist=0x000000011eedc938, rho=0x000000014d047cc8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #95: 0x000000010300085c libR.dylib`Rf_eval(e=0x000000011eedcb30, rho=0x000000014d047cc8) at eval.c:871:12 [opt]
 frame #96: 0x0000000103052d7c libR.dylib`Rf_ReplIteration(rho=0x000000014d047cc8, savestack=<unavailable>, browselevel=<unavailable>, state=0x000000016d6a59b0) at main.c:264:2 [opt]
 frame #97: 0x00000001030542ac libR.dylib`R_ReplConsole(rho=0x000000014d047cc8, savestack=0, browselevel=0) at main.c:316:11 [opt]
 frame #98: 0x00000001030541e4 libR.dylib`run_Rmainloop at main.c:1137:5 [opt]
 frame #99: 0x0000000103054390 libR.dylib`Rf_mainloop at main.c:1144:5 [opt]
 frame #100: 0x000000010275bea0 R`main + 32
 frame #101: 0x0000000102acd08c dyld`start + 520

bt
* thread #1, queue = 'com.apple.main-thread', stop reason = signal SIGSTOP
 * frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x0000000158803e6c libarrow.1100.0.0.dylib`void std::__1::condition_variable::wait<arrow::internal::SerialExecutor::RunLoop()::$_0>(this=0x0000600002dcd048, __lk=0x000000016d696e68, __pred=(0x000000016d696ed8))::$_0) at __mutex_base:404:9
 frame #4: 0x00000001588034c0 libarrow.1100.0.0.dylib`arrow::internal::SerialExecutor::RunLoop(this=0x000000016d696ed8) at thread_pool.cc:174:28
 frame #5: 0x0000000105a39c64 arrow.so`arrow::Future<std::__1::shared_ptr<arrow::Table>> arrow::internal::SerialExecutor::Run<std::__1::shared_ptr<arrow::Table>, arrow::Result<std::__1::shared_ptr<arrow::Table>>>(this=0x000000016d696ed8, initial_task=arrow::internal::SerialExecutor::TopLevelTask<std::__1::shared_ptr<arrow::Table> > @ 0x000000016d696ed0)>) at thread_pool.h:392:5 [opt]
 frame #6: 0x0000000105a3983c arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> arrow::internal::SerialExecutor::RunInSerialExecutor<std::__1::shared_ptr<arrow::Table>, arrow::Future<std::__1::shared_ptr<arrow::Table>>, arrow::Result<std::__1::shared_ptr<arrow::Table>>>(initial_task=arrow::internal::SerialExecutor::TopLevelTask<std::__1::shared_ptr<arrow::Table> > @ 0x000000016d696f30)>) at thread_pool.h:289:38 [opt]
 frame #7: 0x0000000105a395e4 arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> RunWithCapturedR<std::__1::shared_ptr<arrow::Table>>(make_arrow_call=function<arrow::Future<std::__1::shared_ptr<arrow::Table> > ()> @ 0x000000016d696fc8)>) at safe-call-into-r.h:287:29 [opt]
 frame #8: 0x0000000105a2a29c arrow.so`arrow::Result<std::__1::shared_ptr<arrow::Table>> RunWithCapturedRIfPossible<std::__1::shared_ptr<arrow::Table>>(make_arrow_call=function<arrow::Result<std::__1::shared_ptr<arrow::Table> > ()> @ 0x000000016d697020)>) at safe-call-into-r.h:314:12 [opt]
 frame #9: 0x0000000105a2a144 arrow.so`Table__from_ExecPlanReader(reader=<unavailable>) at compute-exec.cpp:195:17 [opt]
 frame #10: 0x00000001059d9668 arrow.so`::_arrow_Table__from_ExecPlanReader(reader_sexp=<unavailable>) at arrowExports.cpp:927:24 [opt]
 frame #11: 0x0000000102fd1be4 libR.dylib`R_doDotCall(ofun=<unavailable>, nargs=<unavailable>, cargs=<unavailable>, call=0x000000011f788dd8) at dotcode.c:601:17 [opt]
 frame #12: 0x000000010301a2dc libR.dylib`bcEval(body=0x000000011f786320, rho=<unavailable>, useCache=<unavailable>) at eval.c:7692:21 [opt]
 frame #13: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f786320, rho=0x000000011f788710) at eval.c:748:8 [opt]
 frame #14: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011ed54250, newrho=0x000000011f788710, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #15: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011ed54250, op=0x000000011f786ba8, arglist=0x000000011f788780, rho=0x000000011f786cf8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #16: 0x000000010300085c libR.dylib`Rf_eval(e=0x000000011ed54250, rho=0x000000011f786cf8) at eval.c:871:12 [opt]
 frame #17: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f787b68, newrho=0x000000011f786cf8, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #18: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f787b68, op=0x000000011f75fa50, arglist=0x000000014d00c0e0, rho=0x000000011f786f28, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #19: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f7853f8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #20: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f7853f8, rho=0x000000011f786f28) at eval.c:748:8 [opt]
 frame #21: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f786fd0, newrho=0x000000011f786f28, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #22: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f786fd0, op=0x000000011f785fc8, arglist=0x000000011e00e070, rho=0x000000011e00df90, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #23: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #24: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000014f57ad00, sxp=0x000000011f785fc8, dotClass=0x00000001286427e8, cptr=0x000000016d69be00, method=0x000000014dd012e0, generic=<unavailable>, rho=0x000000011e00df90, callrho=<unavailable>, defrho=0x000000014dc50180) at objects.c:436:16 [opt]
 frame #25: 0x0000000103069088 libR.dylib`Rf_usemethod(generic="as_arrow_table", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000011e00df90, callrho=0x000000011e00e0e0, defrho=0x000000014dc50180, ans=0x000000016d69b4c0) at objects.c:472:10 [opt]
 frame #26: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000014f576248, op=<unavailable>, args=<unavailable>, env=0x000000011e00df90) at objects.c:565:9 [opt]
 frame #27: 0x0000000103008170 libR.dylib`bcEval(body=0x000000014f578bb0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #28: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f578bb0, rho=0x000000011e00df90) at eval.c:748:8 [opt]
 frame #29: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011e009970, newrho=0x000000011e00df90, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #30: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011e009970, op=0x000000014f57ad00, arglist=0x000000011e00e070, rho=0x000000011e00e0e0, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #31: 0x0000000103007770 libR.dylib`bcEval(body=0x000000012e7fbff8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #32: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000012e7fbff8, rho=0x000000011e00e0e0) at eval.c:748:8 [opt]
 frame #33: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011e00a278, newrho=0x000000011e00e0e0, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #34: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011e00a278, op=0x000000012e7f8fc8, arglist=0x000000012e7f92a0, rho=0x000000012e7f91c0, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #35: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #36: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000014f57ad00, sxp=0x000000012e7f8fc8, dotClass=0x000000012f7d7238, cptr=0x000000016d69daa0, method=0x000000014dd01eb0, generic=<unavailable>, rho=0x000000012e7f91c0, callrho=<unavailable>, defrho=0x000000014dc50180) at objects.c:436:16 [opt]
 frame #37: 0x0000000103069180 libR.dylib`Rf_usemethod(generic="as_arrow_table", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000012e7f91c0, callrho=0x000000012e7f6a78, defrho=0x000000014dc50180, ans=0x000000016d69d160) at objects.c:0 [opt]
 frame #38: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000014f576248, op=<unavailable>, args=<unavailable>, env=0x000000012e7f91c0) at objects.c:565:9 [opt]
 frame #39: 0x0000000103008170 libR.dylib`bcEval(body=0x000000014f578bb0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #40: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f578bb0, rho=0x000000012e7f91c0) at eval.c:748:8 [opt]
 frame #41: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f8bc400, newrho=0x000000012e7f91c0, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #42: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f8bc400, op=0x000000014f57ad00, arglist=0x000000012e7f92a0, rho=0x000000012e7f6a78, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #43: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f8be208, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #44: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f8be208, rho=0x000000012e7f6a78) at eval.c:748:8 [opt]
 frame #45: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f6a40) at eval.c:568:8 [opt]
 frame #46: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f6a40, symbol=0x000000014d05e750, rho=0x000000012e7f6880, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #47: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f6880, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #48: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f192c18, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #49: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f192c18, rho=0x000000012e7f6880) at eval.c:748:8 [opt]
 frame #50: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f63e8) at eval.c:568:8 [opt]
 frame #51: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f63e8, symbol=0x000000014d05e750, rho=0x000000012e7fa110, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #52: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7fa110, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #53: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f190a78, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #54: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f190a78, rho=0x000000012e7fa110) at eval.c:748:8 [opt]
 frame #55: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7fa068) at eval.c:568:8 [opt]
 frame #56: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7fa068, symbol=0x000000014d05e750, rho=0x000000012e7f9dc8, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #57: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f9dc8, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #58: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f192f60, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #59: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f192f60, rho=0x000000012e7f9dc8) at eval.c:748:8 [opt]
 frame #60: 0x000000010301bae4 libR.dylib`forcePromise(e=0x000000012e7f9d20) at eval.c:568:8 [opt]
 frame #61: 0x00000001030279b8 libR.dylib`getvar [inlined] FORCE_PROMISE(value=0x000000012e7f9d20, symbol=0x000000014d05e750, rho=0x000000012e7f9700, keepmiss=FALSE) at eval.c:5157:15 [opt]
 frame #62: 0x00000001030279b0 libR.dylib`getvar(symbol=0x000000014d05e750, rho=0x000000012e7f9700, dd=<unavailable>, keepmiss=FALSE, vcache=<unavailable>, sidx=<unavailable>) at eval.c:5198:14 [opt]
 frame #63: 0x0000000103004b50 libR.dylib`bcEval(body=0x000000014f1932e0, rho=<unavailable>, useCache=<unavailable>) at eval.c:6888:20 [opt]
 frame #64: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f1932e0, rho=0x000000012e7f9700) at eval.c:748:8 [opt]
 frame #65: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f1900a0, newrho=0x000000012e7f9700, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #66: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f1900a0, op=0x000000012e7f9d90, arglist=0x000000012e7f9968, rho=0x000000012e7f9dc8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #67: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f1907a0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #68: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f1907a0, rho=0x000000012e7f9dc8) at eval.c:748:8 [opt]
 frame #69: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f18d0e0, newrho=0x000000012e7f9dc8, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #70: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f18d0e0, op=0x000000012e7f67d8, arglist=0x000000012e7fa030, rho=0x000000012e7fa110, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #71: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f18db60, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #72: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f18db60, rho=0x000000012e7fa110) at eval.c:748:8 [opt]
 frame #73: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000014f18dd58, newrho=0x000000012e7fa110, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #74: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000014f18dd58, op=0x000000012e7f6848, arglist=0x000000012e7f63b0, rho=0x000000012e7f6880, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #75: 0x0000000103007770 libR.dylib`bcEval(body=0x000000014f17aec8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #76: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000014f17aec8, rho=0x000000012e7f6880) at eval.c:748:8 [opt]
 frame #77: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f8bc470, newrho=0x000000012e7f6880, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #78: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f8bc470, op=0x000000014f17b018, arglist=0x000000012e7f6a08, rho=0x000000012e7f6a78, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #79: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f8bd890, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #80: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f8bd890, rho=0x000000012e7f6a78) at eval.c:748:8 [opt]
 frame #81: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011f745c48, newrho=0x000000012e7f6a78, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #82: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011f745c48, op=0x000000011f8ba240, arglist=0x000000012e7c10e0, rho=0x000000012e7c1188, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #83: 0x0000000103007770 libR.dylib`bcEval(body=0x000000011f7436d0, rho=<unavailable>, useCache=<unavailable>) at eval.c:7104:12 [opt]
 frame #84: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000011f7436d0, rho=0x000000012e7c1188) at eval.c:748:8 [opt]
 frame #85: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000012e7c1268, newrho=0x000000012e7c1188, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #86: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000012e7c1268, op=0x000000011f743fc8, arglist=0x000000011eedc938, rho=0x000000011eedc890, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #87: 0x000000010306abb4 libR.dylib`applyMethod(call=<unavailable>, op=<unavailable>, args=<unavailable>, rho=<unavailable>, newvars=<unavailable>) at objects.c:118:8 [opt] [artificial]
 frame #88: 0x00000001030694c0 libR.dylib`dispatchMethod(op=0x000000012822fa60, sxp=0x000000011f743fc8, dotClass=0x000000012f7d7238, cptr=0x000000016d6a5450, method=0x000000014dc4de20, generic=<unavailable>, rho=0x000000011eedc890, callrho=<unavailable>, defrho=0x000000012ebade50) at objects.c:436:16 [opt]
 frame #89: 0x0000000103069180 libR.dylib`Rf_usemethod(generic="collect", obj=<unavailable>, call=<unavailable>, args=<unavailable>, rho=0x000000011eedc890, callrho=0x000000014d047cc8, defrho=0x000000012ebade50, ans=0x000000016d6a4b10) at objects.c:0 [opt]
 frame #90: 0x0000000103069828 libR.dylib`do_usemethod(call=0x000000012822f600, op=<unavailable>, args=<unavailable>, env=0x000000011eedc890) at objects.c:565:9 [opt]
 frame #91: 0x0000000103008170 libR.dylib`bcEval(body=0x000000012822f6a8, rho=<unavailable>, useCache=<unavailable>) at eval.c:7156:15 [opt]
 frame #92: 0x0000000103000588 libR.dylib`Rf_eval(e=0x000000012822f6a8, rho=0x000000011eedc890) at eval.c:748:8 [opt]
 frame #93: 0x000000010301db94 libR.dylib`R_execClosure(call=0x000000011eedcb30, newrho=0x000000011eedc890, sysparent=<unavailable>, rho=<unavailable>, arglist=<unavailable>, op=<unavailable>) at eval.c:0 [opt]
 frame #94: 0x000000010301c3cc libR.dylib`Rf_applyClosure(call=0x000000011eedcb30, op=0x000000012822fa60, arglist=0x000000011eedc938, rho=0x000000014d047cc8, suppliedvars=<unavailable>) at eval.c:1844:16 [opt]
 frame #95: 0x000000010300085c libR.dylib`Rf_eval(e=0x000000011eedcb30, rho=0x000000014d047cc8) at eval.c:871:12 [opt]
 frame #96: 0x0000000103052d7c libR.dylib`Rf_ReplIteration(rho=0x000000014d047cc8, savestack=<unavailable>, browselevel=<unavailable>, state=0x000000016d6a59b0) at main.c:264:2 [opt]
 frame #97: 0x00000001030542ac libR.dylib`R_ReplConsole(rho=0x000000014d047cc8, savestack=0, browselevel=0) at main.c:316:11 [opt]
 frame #98: 0x00000001030541e4 libR.dylib`run_Rmainloop at main.c:1137:5 [opt]
 frame #99: 0x0000000103054390 libR.dylib`Rf_mainloop at main.c:1144:5 [opt]
 frame #100: 0x000000010275bea0 R`main + 32
 frame #101: 0x0000000102acd08c dyld`start + 520

bt
 thread #2
 frame #0: 0x00000001b114e06c libsystem_kernel.dylib`__semwait_signal + 8
 frame #1: 0x00000001b1056fc8 libsystem_c.dylib`nanosleep + 220
 frame #2: 0x0000000102eebf70 cli.so`clic_thread_func(arg=<unavailable>) at thread.c:37:5 [opt]

frame #3: 0x00000001b118826c libsystem_pthread.dylib`_pthread_start + 148
bt
 thread #3
 frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x00000001587900e4 libarrow.1100.0.0.dylib`void std::__1::condition_variable::wait<arrow::ConcreteFutureImpl::DoWait()::'lambda'()>(this=0x0000600002dcef08, __lk=0x000000016d9ea6e8, __pred=(0x0000600002dcee80))::'lambda'()) at __mutex_base:404:9
 frame #4: 0x000000015878e750 libarrow.1100.0.0.dylib`arrow::ConcreteFutureImpl::DoWait(this=0x0000600002dcee80) at future.cc:154:9
 frame #5: 0x000000015878e6dc libarrow.1100.0.0.dylib`arrow::FutureImpl::Wait(this=0x0000600002dcee80) at future.cc:189:52
 frame #6: 0x0000000105a3bdb8 arrow.so`ExecPlanReader::ReadNext(std::__1::shared_ptr<arrow::RecordBatch>*) [inlined] arrow::Future<std::__1::optional<arrow::compute::ExecBatch>>::Wait(this=0x000000016d9ea740) const at future.h:385:12 [opt]
 frame #7: 0x0000000105a3bdb0 arrow.so`ExecPlanReader::ReadNext(std::__1::shared_ptr<arrow::RecordBatch>*) [inlined] arrow::Future<std::__1::optional<arrow::compute::ExecBatch>>::result(this=0x000000016d9ea740) const & at future.h:356:5 [opt]
 frame #8: 0x0000000105a3bdb0 arrow.so`ExecPlanReader::ReadNext(this=0x00006000036fc998, batch_out=0x000000016d9ea880) at compute-exec.cpp:118:28 [opt]
 frame #9: 0x0000000105add178 arrow.so`RecordBatchReaderHead::ReadNext(this=0x0000600003bfd238, batch_out=0x000000016d9ea880) at recordbatchreader.cpp:142:5 [opt]
 frame #10: 0x00000001091358c4 libarrow_dataset.1100.0.0.dylib`arrow::RecordBatchReader::Next(this=0x0000600003bfd238) at record_batch.h:243:5
 frame #11: 0x000000010932b414 libarrow_dataset.1100.0.0.dylib`arrow::Iterator<arrow::RecordBatchReader::ValueType> arrow::MakeIteratorFromReader<arrow::RecordBatchReader>(this=(std::__1::shared_ptr<arrow::RecordBatchReader>::element_type @ 0x0000600003bfd238 strong=2 weak=1))::'lambda'()::operator()() const at iterator.h:565:57
 frame #12: 0x000000010932b3e0 libarrow_dataset.1100.0.0.dylib`arrow::FunctionIterator<arrow::Iterator<arrow::RecordBatchReader::ValueType> arrow::MakeIteratorFromReader<arrow::RecordBatchReader>(std::__1::shared_ptr<arrow::RecordBatchReader> const&)::'lambda'(), std::__1::shared_ptr<arrow::RecordBatch>>::Next(this=0x0000600001afe010) at iterator.h:346:29
 frame #13: 0x000000010932b380 libarrow_dataset.1100.0.0.dylib`arrow::Result<std::__1::shared_ptr<arrow::RecordBatch>> arrow::Iterator<std::__1::shared_ptr<arrow::RecordBatch>>::Next<arrow::FunctionIterator<arrow::Iterator<arrow::RecordBatchReader::ValueType> arrow::MakeIteratorFromReader<arrow::RecordBatchReader>(ptr=0x0000600001afe010)::'lambda'(), std::__1::shared_ptr<arrow::RecordBatch>>>(void*) at iterator.h:200:40
 frame #14: 0x000000010915cb50 libarrow_dataset.1100.0.0.dylib`arrow::Iterator<std::__1::shared_ptr<arrow::RecordBatch>>::Next(this=0x00006000018c46e8) at iterator.h:110:29
 frame #15: 0x0000000158c7479c libarrow.1100.0.0.dylib`arrow::MapIterator<arrow::compute::MakeReaderGenerator(std::__1::shared_ptr<arrow::RecordBatchReader>, arrow::internal::Executor*, int, int)::$_4, std::__1::shared_ptr<arrow::RecordBatch>, std::__1::optional<arrow::compute::ExecBatch>>::Next(this=0x00006000018c46e0) at iterator.h:428:5
 frame #16: 0x0000000158c74710 libarrow.1100.0.0.dylib`arrow::Result<std::__1::optional<arrow::compute::ExecBatch>> arrow::Iterator<std::__1::optional<arrow::compute::ExecBatch>>::Next<arrow::MapIterator<arrow::compute::MakeReaderGenerator(ptr=0x00006000018c46e0)::$_4, std::__1::shared_ptr<arrow::RecordBatch>, std::__1::optional<arrow::compute::ExecBatch>>>(void*) at iterator.h:200:40
 frame #17: 0x0000000158c5ba5c libarrow.1100.0.0.dylib`arrow::Iterator<std::__1::optional<arrow::compute::ExecBatch>>::Next(this=0x0000600002dcc268) at iterator.h:110:29
 frame #18: 0x0000000158c7d264 libarrow.1100.0.0.dylib`arrow::BackgroundGenerator<std::__1::optional<arrow::compute::ExecBatch>>::WorkerTask(state=std::__1::shared_ptr<arrow::BackgroundGenerator<std::__1::optional<arrow::compute::ExecBatch> >::State>::element_type @ 0x0000600002dcc258 strong=3 weak=1) at async_generator.h:1759:29
 frame #19: 0x0000000158c7d1bc libarrow.1100.0.0.dylib`arrow::BackgroundGenerator<std::__1::optional<arrow::compute::ExecBatch>>::State::DoRestartTask(this=(std::__1::shared_ptr<arrow::BackgroundGenerator<std::__1::optional<arrow::compute::ExecBatch> >::State>::element_type @ 0x0000600002dcc258 strong=3 weak=1))::'lambda'()::operator()() const at async_generator.h:1666:23
 frame #20: 0x0000000158c7d138 libarrow.1100.0.0.dylib`arrow::internal::FnOnce<void ()>::FnImpl<arrow::BackgroundGenerator<std::__1::optional<arrow::compute::ExecBatch>>::State::DoRestartTask(this=0x00006000018c4aa0)::'lambda'()>::invoke() at functional.h:152:42
 frame #21: 0x0000000158803d3c libarrow.1100.0.0.dylib`arrow::internal::FnOnce<void ()>::operator(this=0x000000016d9eae38)() && at functional.h:140:17
 frame #22: 0x000000015881683c libarrow.1100.0.0.dylib`arrow::internal::WorkerLoop(state=std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9dbd78 strong=3 weak=2, it=std::__1::list<std::__1::thread, std::__1::allocator<std::__1::thread> >::iterator @ 0x000000016d9eaed8) at thread_pool.cc:262:11
 frame #23: 0x0000000158816548 libarrow.1100.0.0.dylib`arrow::internal::ThreadPool::LaunchWorkersUnlocked(this=(0x00006000016fc0f0, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9dbd78 strong=3 weak=2, {...}))::$_6::operator()() const at thread_pool.cc:423:7
 frame #24: 0x00000001588164a4 libarrow.1100.0.0.dylib`decltype(__f=(0x00006000016fc0f0, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9dbd78 strong=3 weak=2, {...}))::$_6>(fp)()) std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6&&) at type_traits:3918:1
 frame #25: 0x0000000158816440 libarrow.1100.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)::$_6>(__t=size=2, (null)=__tuple_indices<> @ 0x000000016d9eaf7f)::$_6>&, std::__1::__tuple_indices<>) at thread:287:5
 frame #26: 0x0000000158815bdc libarrow.1100.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)::$_6>>(__vp=0x00006000016fc030) at thread:298:5
 frame #27: 0x00000001b118826c libsystem_pthread.dylib`_pthread_start + 148

bt
 thread #4
 frame #0: 0x00000001b114b634 libsystem_kernel.dylib`read + 8
 frame #1: 0x00000001587d0190 libarrow.1100.0.0.dylib`arrow::internal::(anonymous namespace)::SelfPipeImpl::Wait(this=0x0000600003bfcf68) at io_util.cc:1268:24
 frame #2: 0x000000015876d45c libarrow.1100.0.0.dylib`arrow::(anonymous namespace)::SignalStopState::ReceiveSignals(self_pipe=std::__1::shared_ptr<arrow::internal::SelfPipe>::element_type @ 0x0000600003bfcf68 strong=2 weak=3) at cancel.cc:246:39
 frame #3: 0x000000015876e3fc libarrow.1100.0.0.dylib`decltype(__f=0x00006000018c4248, __args=nullptr)(static_cast<std::__1::shared_ptr<arrow::internal::SelfPipe>>(fp0))) std::__1::__invoke<void (*)(std::__1::shared_ptr<arrow::internal::SelfPipe>), std::__1::shared_ptr<arrow::internal::SelfPipe>>(void (*&&)(std::__1::shared_ptr<arrow::internal::SelfPipe>), std::__1::shared_ptr<arrow::internal::SelfPipe>&&) at type_traits:3918:1
 frame #4: 0x000000015876e374 libarrow.1100.0.0.dylib`void std::__1::__thread_execute<std::__1::unique_ptr<std::__1::__thread_struct, std::__1::default_delete<std::__1::__thread_struct>>, void (*)(std::__1::shared_ptr<arrow::internal::SelfPipe>), std::__1::shared_ptr<arrow::internal::SelfPipe>, 2ul>(__t=size=3, (null)=__tuple_indices<2> @ 0x000000016dc1af7f)(std::__1::shared_ptr<arrow::internal::SelfPipe>), std::__1::shared_ptr<arrow::internal::SelfPipe>>&, std::__1::__tuple_indices<2ul>) at thread:287:5
 frame #5: 0x000000015876da14 libarrow.1100.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>>, void (*)(std::__1::shared_ptr<arrow::internal::SelfPipe>), std::__1::shared_ptr<arrow::internal::SelfPipe>>>(__vp=0x00006000018c4240) at thread:298:5

frame #6: 0x00000001b118826c libsystem_pthread.dylib`_pthread_start + 148
bt
 thread #5
 frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x000000015881698c libarrow.1100.0.0.dylib`arrow::internal::WorkerLoop(state=std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, it=std::__1::list<std::__1::thread, std::__1::allocator<std::__1::thread> >::iterator @ 0x000000016dca6ed8) at thread_pool.cc:280:16
 frame #4: 0x0000000158816548 libarrow.1100.0.0.dylib`arrow::internal::ThreadPool::LaunchWorkersUnlocked(this=(0x00006000016fc090, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, {...}))::$_6::operator()() const at thread_pool.cc:423:7
 frame #5: 0x00000001588164a4 libarrow.1100.0.0.dylib`decltype(__f=(0x00006000016fc090, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, {...}))::$_6>(fp)()) std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6&&) at type_traits:3918:1
 frame #6: 0x0000000158816440 libarrow.1100.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)::$_6>(__t=size=2, (null)=__tuple_indices<> @ 0x000000016dca6f7f)::$_6>&, std::__1::__tuple_indices<>) at thread:287:5
 frame #7: 0x0000000158815bdc libarrow.1100.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)::$_6>>(__vp=0x00006000016fcae0) at thread:298:5
 frame #8: 0x00000001b118826c libsystem_pthread.dylib`_pthread_start + 148

bt
 thread #6
 frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x00000001587900e4 libarrow.1100.0.0.dylib`void std::__1::condition_variable::wait<arrow::ConcreteFutureImpl::DoWait()::'lambda'()>(this=0x0000600002dcd888, __lk=0x000000016dd32a28, __pred=(0x0000600002dcd800))::'lambda'()) at __mutex_base:404:9
 frame #4: 0x000000015878e750 libarrow.1100.0.0.dylib`arrow::ConcreteFutureImpl::DoWait(this=0x0000600002dcd800) at future.cc:154:9
 frame #5: 0x000000015878e6dc libarrow.1100.0.0.dylib`arrow::FutureImpl::Wait(this=0x0000600002dcd800) at future.cc:189:52
 frame #6: 0x0000000105a3bdb8 arrow.so`ExecPlanReader::ReadNext(std::__1::shared_ptr<arrow::RecordBatch>*) [inlined] arrow::Future<std::__1::optional<arrow::compute::ExecBatch>>::Wait(this=0x000000016dd32a80) const at future.h:385:12 [opt]
 frame #7: 0x0000000105a3bdb0 arrow.so`ExecPlanReader::ReadNext(std::__1::shared_ptr<arrow::RecordBatch>*) [inlined] arrow::Future<std::__1::optional<arrow::compute::ExecBatch>>::result(this=0x000000016dd32a80) const & at future.h:356:5 [opt]
 frame #8: 0x0000000105a3bdb0 arrow.so`ExecPlanReader::ReadNext(this=0x00006000036fca98, batch_out=0x000000016dd32b88) at compute-exec.cpp:118:28 [opt]
 frame #9: 0x00000001584b51a4 libarrow.1100.0.0.dylib`arrow::RecordBatchReader::ToRecordBatches(this=0x00006000036fca98) at record_batch.cc:334:5
 frame #10: 0x00000001584b56ac libarrow.1100.0.0.dylib`arrow::RecordBatchReader::ToTable(this=0x00006000036fca98) at record_batch.cc:348:3
 frame #11: 0x0000000105a3b090 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>>::invoke() [inlined] std::__1::__function::__value_func<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>::operator(this=<unavailable>)() const at function.h:505:16 [opt]
 frame #12: 0x0000000105a3b078 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>>::invoke() [inlined] std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>::operator(this=<unavailable>)() const at function.h:1182:12 [opt]
 frame #13: 0x0000000105a3b078 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>>::invoke() [inlined] std::__1::enable_if<!std::is_void<arrow::Result<std::__1::shared_ptr<arrow::Table>>>::value && !is_future<arrow::Result<std::__1::shared_ptr<arrow::Table>>>::value && (!arrow::Future<std::__1::shared_ptr<arrow::Table>>::is_empty || std::is_same<arrow::Result<std::__1::shared_ptr<arrow::Table>>, arrow::Status>::value), void>::type arrow::detail::ContinueFuture::operator(this=<unavailable>, next=Future<std::__1::shared_ptr<arrow::Table> > @ 0x000000016dd32ca0, f=<unavailable>)<std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>&, arrow::Result<std::__1::shared_ptr<arrow::Table>>, arrow::Future<std::__1::shared_ptr<arrow::Table>>>(arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>&) const at future.h:150:23 [opt]
 frame #14: 0x0000000105a3b078 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>>::invoke() [inlined] decltype(__f=<unavailable>, __args=<unavailable>, __args=<unavailable>)(static_cast<arrow::Future<std::__1::shared_ptr<arrow::Table>>&>(fp0), static_cast<std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>&>(fp0))) std::__1::__invoke<arrow::detail::ContinueFuture&, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>&>(arrow::detail::ContinueFuture&, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>&) at type_traits:3918:1 [opt]
 frame #15: 0x0000000105a3b060 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>>::invoke() [inlined] std::__1::__bind_return<arrow::detail::ContinueFuture, std::__1::tuple<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>, std::__1::tuple<>, __is_valid_bind_return<arrow::detail::ContinueFuture, std::__1::tuple<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>, std::__1::tuple<>>::value>::type std::__1::__apply_functor<arrow::detail::ContinueFuture, std::__1::tuple<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> (__f=<unavailable>, __bound_args=<unavailable>, (null)=<unavailable>, __args=<unavailable>)>>, 0ul, 1ul, std::__1::tuple<>>(arrow::detail::ContinueFuture&, std::__1::tuple<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>&, std::__1::__tuple_indices<0ul, 1ul>, std::__1::tuple<>&&) at bind.h:257:12 [opt]
 frame #16: 0x0000000105a3b060 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>>::invoke() [inlined] std::__1::__bind_return<arrow::detail::ContinueFuture, std::__1::tuple<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>, std::__1::tuple<>, __is_valid_bind_return<arrow::detail::ContinueFuture, std::__1::tuple<arrow::Future<std::__1::shared_ptr<arrow::Table>>, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> ()>>, std::__1::tuple<>>::value>::type std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> (this=<unavailable>)>>::operator()<>() at bind.h:292:20 [opt]
 frame #17: 0x0000000105a3b060 arrow.so`arrow::internal::FnOnce<void ()>::FnImpl<std::__1::__bind<arrow::detail::ContinueFuture, arrow::Future<std::__1::shared_ptr<arrow::Table>>&, std::__1::function<arrow::Result<std::__1::shared_ptr<arrow::Table>> (this=<unavailable>)>>>::invoke() at functional.h:152:42 [opt]
 frame #18: 0x0000000158803d3c libarrow.1100.0.0.dylib`arrow::internal::FnOnce<void ()>::operator(this=0x000000016dd32e38)() && at functional.h:140:17
 frame #19: 0x000000015881683c libarrow.1100.0.0.dylib`arrow::internal::WorkerLoop(state=std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, it=std::__1::list<std::__1::thread, std::__1::allocator<std::__1::thread> >::iterator @ 0x000000016dd32ed8) at thread_pool.cc:262:11
 frame #20: 0x0000000158816548 libarrow.1100.0.0.dylib`arrow::internal::ThreadPool::LaunchWorkersUnlocked(this=(0x00006000016fc090, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, {...}))::$_6::operator()() const at thread_pool.cc:423:7
 frame #21: 0x00000001588164a4 libarrow.1100.0.0.dylib`decltype(__f=(0x00006000016fc090, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, {...}))::$_6>(fp)()) std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6&&) at type_traits:3918:1
 frame #22: 0x0000000158816440 libarrow.1100.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)::$_6>(__t=size=2, (null)=__tuple_indices<> @ 0x000000016dd32f7f)::$_6>&, std::__1::__tuple_indices<>) at thread:287:5
 frame #23: 0x0000000158815bdc libarrow.1100.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)::$_6>>(__vp=0x00006000016e55c0) at thread:298:5
 frame #24: 0x00000001b118826c libsystem_pthread.dylib`_pthread_start + 148

bt
 thread #7
 frame #0: 0x00000001b114e270 libsystem_kernel.dylib`__psynch_cvwait + 8
 frame #1: 0x00000001b118883c libsystem_pthread.dylib`_pthread_cond_wait + 1236
 frame #2: 0x00000001b10d7284 libc++.1.dylib`std::__1::condition_variable::wait(std::__1::unique_lock<std::__1::mutex>&) + 28
 frame #3: 0x000000015881698c libarrow.1100.0.0.dylib`arrow::internal::WorkerLoop(state=std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, it=std::__1::list<std::__1::thread, std::__1::allocator<std::__1::thread> >::iterator @ 0x000000016ddbeed8) at thread_pool.cc:280:16
 frame #4: 0x0000000158816548 libarrow.1100.0.0.dylib`arrow::internal::ThreadPool::LaunchWorkersUnlocked(this=(0x00006000016fc090, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, {...}))::$_6::operator()() const at thread_pool.cc:423:7
 frame #5: 0x00000001588164a4 libarrow.1100.0.0.dylib`decltype(__f=(0x00006000016fc090, std::__1::shared_ptr<arrow::internal::ThreadPool::State>::element_type @ 0x000000014e9bdf88 strong=7 weak=2, {...}))::$_6>(fp)()) std::__1::__invoke<arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6>(arrow::internal::ThreadPool::LaunchWorkersUnlocked(int)::$_6&&) at type_traits:3918:1
 frame #6: 0x0000000158816440 libarrow.1100.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)::$_6>(__t=size=2, (null)=__tuple_indices<> @ 0x000000016ddbef7f)::$_6>&, std::__1::__tuple_indices<>) at thread:287:5

frame #7: 0x0000000158815bdc libarrow.1100.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)::$_6>>(__vp=0x00006000016cc8d0) at thread:298:5
 frame #8: 0x00000001b118826c libsystem_pthread.dylib`_pthread_start + 148

[asfimport]

Weston Pace / @westonpace:
Threads #3 and #6 are suspicious. Generally a CPU thread pool thread should not be in a blocked state. Yet both are waiting on futures. That should only happen on user threads (or possibly I/O threads).

[asfimport]

Dewey Dunnington / @paleolimbot:
I think that Thread #3 is the one that was launched to do "arrow stuff" since it contains the calls to ExecPlanReader::ReadNext that I would expect. It's suspicious that Thread #6 has an almost identical backtrace...I wonder if the R package is accidentally launching two threads (it's not supposed to launch additional threads once one has been dispatched).

[asfimport]

Dewey Dunnington / @paleolimbot:
Issue resolved by pull request 14582
#14582