Guest User

datafusion-error-log

a guest
Mar 17th, 2023
133
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 32.70 KB | None | 0 0
  1. thread 'tokio-runtime-worker' panicked at 'index out of bounds: the len is 1 but the index is 1', /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-physical-expr-15.0.0/src/hash_utils.rs:194:40
  2. stack backtrace:
  3. 0: rust_begin_unwind
  4. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:575:5
  5. 1: core::panicking::panic_fmt
  6. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panicking.rs:64:14
  7. 2: core::panicking::panic_bounds_check
  8. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panicking.rs:147:5
  9. 3: datafusion_physical_expr::hash_utils::create_row_hashes
  10. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-physical-expr-15.0.0/src/hash_utils.rs:194:40
  11. 4: datafusion::physical_plan::aggregates::row_hash::group_aggregate_batch
  12. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:312:9
  13. 5: datafusion::physical_plan::aggregates::row_hash::GroupedHashAggregateStreamV2::new::{{closure}}::{{closure}}
  14. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:182:42
  15. 6: <futures_util::stream::unfold::Unfold<T,F,Fut> as futures_core::stream::Stream>::poll_next
  16. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/unfold.rs:107:33
  17. 7: <futures_util::stream::stream::fuse::Fuse<S> as futures_core::stream::Stream>::poll_next
  18. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/fuse.rs:53:27
  19. 8: <core::pin::Pin<P> as futures_core::stream::Stream>::poll_next
  20. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-core-0.3.25/src/stream.rs:120:9
  21. 9: futures_util::stream::stream::StDT: 2023-03-10 12:34:38.920 +00:00
  22. reamExt::poll_next_unpin
  23. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/mod.rs:1626:9
  24. 10thread ': tokio-runtime-worker<' panicked at 'datafusionindex out of bounds: the len is 1 but the index is 1::', physical_plan/Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-physical-expr-15.0.0/src/hash_utils.rs:::aggregates194:::row_hash40::
  25. GroupedHashAggregateStreamV2 as futures_core::stream::Stream>::poll_next
  26. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:260:9
  27. 11: <core::pin::Pin<P> as futures_core::stream::Stream>::poll_next
  28. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-core-0.3.25/src/stream.rs:120:9
  29. 12: futures_util::stream::stream::StreamExt::poll_next_unpin
  30. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/mod.rs:1626:9
  31. 13: <futures_util::stream::stream::next::Next<St> as core::future::future::Future>::poll
  32. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/next.rs:32:9
  33. 14: datafusion::physical_plan::repartition::RepartitionExec::pull_from_input::{{closure}}
  34. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/repartition.rs:445:39
  35. 15: tokio::runtime::task::core::CoreStage<T>::poll::{{closure}}
  36. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:184:17
  37. 16: tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
  38. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/loom/std/unsafe_cell.rs:14:9
  39. 17: tokio::runtime::task::core::CoreStage<T>::poll
  40. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:174:13
  41. 18: tokio::runtime::taskDT: 2023-03-05 06:18:53.987 +00:00
  42. ::harness::poll_future::{{closure}}
  43. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:480:19
  44. 19: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
  45. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panic/unwind_safe.rs:271:9
  46. 20: std::panicking::try::do_call
  47. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:483:40
  48. 21: ___rust_try
  49. 22: std::panicking::try
  50. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:447:19
  51. 23: std::panic::catch_unwind
  52. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panic.rs:137:14
  53. 24: tokio::runtime::task::harness::poll_future
  54. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:468:18
  55. 25: tokio::runtime::task::harness::Harness<T,S>::poll_inner
  56. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:104:27
  57. 26: tokio::runtime::task::harness::Harness<T,S>::poll
  58. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:57:15
  59. 27: tokio::runtime::task::raw::poll
  60. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:194:5
  61. 28: tokio::runtime::task::raw::RawTask::poll
  62. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:134:18
  63. 29: tokio::runtime::task::LocalNotified<S>::run
  64. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/mod.rs:385:9
  65. 30: tokio::runtime::scheduler::multi_thread::worker::Context::run_task::{{closure}}
  66. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:421:13
  67. 31: tokio::coop::with_budget::{{closure}}
  68. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:102:9
  69. 32: std::thread::local::LocalKey<T>::try_with
  70. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/thread/local.rs:446:16
  71. 33: std::thread::local::LocalKey<T>::with
  72. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/thread/local.rs:422:9
  73. 34: tokio::coop::with_budget
  74. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:95:5
  75. 35: tokio::coop::budget
  76. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:72:5
  77. 36: tokio::runtime::scheduler::multi_thread::worker::Context::run_task
  78. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:420:9
  79. 37: tokio::runtime::scheduler::multi_thread::worker::Context::run
  80. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:394:24
  81. 38: tokio::runtime::scheduler::multi_thread::worker::run::{{closure}}
  82. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:372:17
  83. 39: tokio::macros::scoped_tls::ScopedKey<T>::set
  84. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/macros/scoped_tls.rs:61:9
  85. 40: tokio::runtime::scheduler::multi_thread::worker::run
  86. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:369:5
  87. 41: tokio::runtime::scheduler::multi_thread::worker::Launch::launch::{{closure}}
  88. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:348:45
  89. 42: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll
  90. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/task.rs:42:21
  91. 43: tokio::runtime::task::core::CoreStage<T>::poll::{{closure}}
  92. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:184:17
  93. 44: tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
  94. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/loom/std/unsafe_cell.rs:14:9
  95. 45: tokio::runtime::task::core::CoreStage<T>::poll
  96. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:174:13
  97. 46: tokio::runtime::task::harness::poll_future::{{closure}}
  98. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:480:19
  99. 47: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
  100. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panic/unwind_safe.rs:271:9
  101. 48: std::panicking::try::do_call
  102. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:483:40
  103. 49: ___rust_try
  104. 50: std::panicking::try
  105. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:447:19
  106. 51: std::panic::catch_unwind
  107. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panic.rs:137:14
  108. 52: tokio::runtime::task::harness::poll_future
  109. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:468:18
  110. 53: tokio::runtime::task::harness::Harness<T,S>::poll_inner
  111. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:104:27
  112. 54: tokio::runtime::task::harness::Harness<T,S>::poll
  113. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:57:15
  114. 55: tokio::runtime::task::raw::poll
  115. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:194:5
  116. 56: tokio::runtime::task::raw::RawTask::poll
  117. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:134:18
  118. 57: tokio::runtime::task::UnownedTask<S>::run
  119. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/mod.rs:422:9
  120. 58: tokio::runtime::blocking::pool::Task::run
  121. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:111:9
  122. 59: tokio::runtime::blocking::pool::Inner::run
  123. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:346:17
  124. 60: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}}
  125. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:321:13
  126. note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
  127. stack backtrace:
  128. 0: rust_begin_unwind
  129. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:575:5
  130. 1: core::panicking::panic_fmt
  131. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panicking.rs:64:14
  132. 2: core::panicking::panic_bounds_check
  133. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panicking.rs:147:5
  134. 3: datafusion_physical_expr::hash_utils::create_row_hashes
  135. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-physical-expr-15.0.0/src/hash_utils.rs:194:40
  136. 4: datafusion::physical_plan::aggregates::row_hash::group_aggregate_batch
  137. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:312:9
  138. 5: datafusion::physical_plan::aggregates::row_hash::GroupedHashAggregateStreamV2::new::{{closure}}::{{closure}}
  139. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:182:42
  140. 6: <futures_util::stream::unfold::Unfold<T,F,Fut> as futures_core::stream::Stream>::poll_next
  141. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/unfold.rs:107:33
  142. 7: <futures_util::stream::stream::fuse::Fuse<S> as futures_core::stream::Stream>::poll_next
  143. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/fuse.rs:53:27
  144. 8: <core::pin::Pin<P> as futures_core::stream::Stream>::poll_next
  145. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-core-0.3.25/src/stream.rs:120:9
  146. 9: futures_util::stream::stream::StreamExt::poll_next_unpin
  147. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/mod.rs:1626:9
  148. 10: <datafusion::physical_plan::aggregates::row_hash::GroupedHashAggregateStreamV2 as futures_core::stream::Stream>::poll_next
  149. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:260:9
  150. 11: <core::pin::Pin<P> as futures_core::stream::Stream>::poll_next
  151. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-core-0.3.25/src/stream.rs:120:9
  152. DT: 2023-03-04 12:10:35.295 +00:00
  153. 12: futures_util::stream::stream::StreamExt::poll_next_unpin
  154. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/mod.rs:1626:DT: 2023-03-04 18:25:35.629 +00:00
  155. 9
  156. 13: <futures_util::stream::stream::next::Next<St> as core::future::future::Future>::poll
  157. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/next.rs:32:9
  158. thread 'tokio-runtime-worker' panicked at 'index out of bounds: the len is 1 but the index is 1', /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-physical-expr-15.0.0/src/hash_utils.rs:194:40
  159. 14: datafusion::physical_plan::repartition::RepartitionExec::pull_from_input::{{closure}}
  160. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/repartition.rs:445:39
  161. 15: tokio::runtime::task::core::CoreStage<T>::poll::{{closure}}
  162. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:184:17
  163. 16: tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
  164. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/loom/std/unsafe_cell.rs:14:9
  165. 17: tokio::runtime::task::core::CoreStage<T>::poll
  166. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:174:13
  167. 18: tokio::runtime::task::harness::poll_future::{{closure}}
  168. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:480:19
  169. 19: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
  170. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panic/unwind_safe.rs:271:9
  171. 20: std::panicking::try::do_call
  172. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:483:40
  173. 21: ___rust_try
  174. 22: std::panicking::try
  175. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:447:19
  176. 23: std::panic::catch_unwind
  177. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panic.rs:137:14
  178. 24: tokio::runtime::task::harness::poll_future
  179. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:468:18
  180. 25: tokio::runtime::task::harness::Harness<T,S>::poll_inner
  181. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:104:27
  182. DT: 2023-03-04 01:11:00 +00:00
  183. 26: tokio::runtime::task::harness::Harness<T,S>::poll
  184. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:57:15
  185. 27: tokio::runtime::task::raw::poll
  186. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:194:5
  187. 28: tokio::runtime::task::raw::RawTask::poll
  188. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:134:18
  189. 29: tokio::runtime::task::LocalNotified<S>::run
  190. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/mod.rs:385:9
  191. 30: tokio::runtime::scheduler::multi_thread::worker::Context::run_task::{{closure}}
  192. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:444:21
  193. 31: tokio::coop::with_budget::{{closure}}
  194. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:102:9
  195. 32: std::thread::local::LocalKey<T>::try_with
  196. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/thread/local.rs:446:16
  197. 33: std::thread::local::LocalKey<T>::with
  198. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/thread/local.rs:422:9
  199. 34: tokio::coop::with_budget
  200. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:95:5
  201. 35: tokio::coop::budget
  202. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:72:5
  203. 36: tokio::runtime::scheduler::multi_thread::worker::Context::run_task
  204. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:420:9
  205. 37: tokio::runtime::scheduler::multi_thread::worker::Context::run
  206. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:387:24
  207. 38: tokio::runtime::scheduler::multi_thread::worker::run::{{closure}}
  208. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:372:17
  209. 39: tokio::macros::scoped_tls::ScopedKey<T>::set
  210. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/macros/scoped_tls.rs:61:9
  211. 40: tokio::runtime::scheduler::multi_thread::worker::run
  212. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:369:5
  213. 41: tokio::runtime::scheduler::multi_thread::worker::Launch::launch::{{closure}}
  214. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:348:45
  215. 42: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll
  216. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/task.rs:42:21
  217. 43: tokio::runtime::task::core::CoreStage<T>::poll::{{closure}}
  218. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:184:17
  219. 44: tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
  220. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/loom/std/unsafe_cell.rs:14:9
  221. 45: tokio::runtime::task::core::CoreStage<T>::poll
  222. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:174:13
  223. 46: tokio::runtime::task::harness::poll_future::{{closure}}
  224. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:480:19
  225. 47: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
  226. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panic/unwind_safe.rs:271:9
  227. 48: std::panicking::try::do_call
  228. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:483:40
  229. 49: ___rust_try
  230. 50: std::panicking::try
  231. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:447:19
  232. 51: std::panic::catch_unwind
  233. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panic.rs:137:14
  234. 52: tokio::runtime::task::harness::poll_future
  235. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:468:18
  236. 53: tokio::runtime::task::harness::Harness<T,S>::poll_inner
  237. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:104:27
  238. 54: tokio::runtime::task::harness::Harness<T,S>::poll
  239. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:57:15
  240. 55: tokio::runtime::task::raw::poll
  241. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:194:5
  242. 56: tokio::runtime::task::raw::RawTask::poll
  243. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:134:18
  244. 57: tokio::runtime::task::UnownedTask<S>::run
  245. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/mod.rs:422:9
  246. 58: tokio::runtime::blocking::pool::Task::run
  247. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:111:9
  248. 59: tokio::runtime::blocking::pool::Inner::run
  249. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:346:17
  250. 60: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}}
  251. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:321:13
  252. note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
  253. stack backtrace:
  254. 0: rust_begin_unwind
  255. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:575:5
  256. 1: core::panicking::panic_fmt
  257. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panicking.rs:64:14
  258. 2: core::panicking::panic_bounds_check
  259. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panicking.rs:147:5
  260. 3: datafusion_physical_expr::hash_utils::create_row_hashes
  261. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-physical-expr-15.0.0/src/hash_utils.rs:194:40
  262. 4: datafusion::physical_plan::aggregates::row_hash::group_aggregate_batch
  263. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:312:9
  264. 5: datafusion::physical_plan::aggregates::row_hash::GroupedHashAggregateStreamV2::new::{{closure}}::{{closure}}
  265. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:182:42
  266. 6: <futures_util::stream::unfold::Unfold<T,F,Fut> as futures_core::stream::Stream>::poll_next
  267. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/unfold.rs:107:33
  268. 7: <futures_util::stream::stream::fuse::Fuse<S> as futures_core::stream::Stream>::poll_next
  269. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/fuse.rs:53:27
  270. 8: <core::pin::Pin<P> as futures_core::stream::Stream>::poll_next
  271. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-core-0.3.25/src/stream.rs:120:9
  272. 9: futures_util::stream::stream::StreamExt::poll_next_unpin
  273. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/mod.rs:1626:9
  274. 10: <datafusion::physical_plan::aggregates::row_hash::GroupedHashAggregateStreamV2 as futures_core::stream::Stream>::poll_next
  275. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/aggregates/row_hash.rs:260:9
  276. 11: <core::pin::Pin<P> as futures_core::stream::Stream>::poll_next
  277. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-core-0.3.25/src/stream.rs:120:9
  278. 12: futures_util::stream::stream::StreamExt::poll_next_unpin
  279. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/mod.rs:1626:9
  280. 13: <futures_util::stream::stream::next::Next<St> as core::future::future::Future>::poll
  281. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-util-0.3.25/src/stream/stream/next.rs:32:9
  282. 14: datafusion::physical_plan::repartition::RepartitionExec::pull_from_input::{{closure}}
  283. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/datafusion-15.0.0/src/physical_plan/repartition.rs:445:39
  284. 15: tokio::runtime::task::core::CoreStage<T>::poll::{{closure}}
  285. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:184:17
  286. 16: tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
  287. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/loom/std/unsafe_cell.rs:14:9
  288. 17: tokio::runtime::task::core::CoreStage<T>::poll
  289. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:174:13
  290. 18: tokio::runtime::task::harness::poll_future::{{closure}}
  291. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:480:19
  292. 19: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
  293. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panic/unwind_safe.rs:271:9
  294. 20: std::panicking::try::do_call
  295. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:483:40
  296. 21: ___rust_try
  297. 22: std::panicking::try
  298. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:447:19
  299. 23: std::panic::catch_unwind
  300. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panic.rs:137:14
  301. 24: tokio::runtime::task::harness::poll_future
  302. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:468:18
  303. 25: tokio::runtime::task::harness::Harness<T,S>::poll_inner
  304. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:104:27
  305. 26: tokio::runtime::task::harness::Harness<T,S>::poll
  306. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:57:15
  307. 27: tokio::runtime::task::raw::poll
  308. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:194:5
  309. 28: tokio::runtime::task::raw::RawTask::poll
  310. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:134:18
  311. 29: tokio::runtime::task::LocalNotified<S>::run
  312. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/mod.rs:385:9
  313. 30: tokio::runtime::scheduler::multi_thread::worker::Context::run_task::{{closure}}
  314. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:421:13
  315. 31: tokio::coop::with_budget::{{closure}}
  316. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:102:9
  317. 32: std::thread::local::LocalKey<T>::try_with
  318. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/thread/local.rs:446:16
  319. 33: std::thread::local::LocalKey<T>::with
  320. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/thread/local.rs:422:9
  321. 34: tokio::coop::with_budget
  322. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:95:5
  323. 35: tokio::coop::budget
  324. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/coop.rs:72:5
  325. 36: tokio::runtime::scheduler::multi_thread::worker::Context::run_task
  326. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:420:9
  327. 37: tokio::runtime::scheduler::multi_thread::worker::Context::run
  328. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:394:24
  329. 38: tokio::runtime::scheduler::multi_thread::worker::run::{{closure}}
  330. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:372:17
  331. 39: tokio::macros::scoped_tls::ScopedKey<T>::set
  332. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/macros/scoped_tls.rs:61:9
  333. 40: tokio::runtime::scheduler::multi_thread::worker::run
  334. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:369:5
  335. 41: tokio::runtime::scheduler::multi_thread::worker::Launch::launch::{{closure}}
  336. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/scheduler/multi_thread/worker.rs:348:45
  337. 42: <tokio::runtime::blocking::task::BlockingTask<T> as core::future::future::Future>::poll
  338. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/task.rs:42:21
  339. 43: tokio::runtime::task::core::CoreStage<T>::poll::{{closure}}
  340. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:184:17
  341. 44: tokio::loom::std::unsafe_cell::UnsafeCell<T>::with_mut
  342. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/loom/std/unsafe_cell.rs:14:9
  343. 45: tokio::runtime::task::core::CoreStage<T>::poll
  344. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/core.rs:174:13
  345. 46: tokio::runtime::task::harness::poll_future::{{closure}}
  346. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:480:19
  347. 47: <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once
  348. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/core/src/panic/unwind_safe.rs:271:9
  349. 48: std::panicking::try::do_call
  350. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:483:40
  351. 49: ___rust_try
  352. 50: std::panicking::try
  353. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panicking.rs:447:19
  354. 51: std::panic::catch_unwind
  355. at /rustc/d5a82bbd26e1ad8b7401f6a718a9c57c96905483/library/std/src/panic.rs:137:14
  356. 52: tokio::runtime::task::harness::poll_future
  357. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:468:18
  358. 53: tokio::runtime::task::harness::Harness<T,S>::poll_inner
  359. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:104:27
  360. 54: tokio::runtime::task::harness::Harness<T,S>::poll
  361. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/harness.rs:57:15
  362. 55: tokio::runtime::task::raw::poll
  363. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:194:5
  364. 56: tokio::runtime::task::raw::RawTask::poll
  365. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/raw.rs:134:18
  366. 57: tokio::runtime::task::UnownedTask<S>::run
  367. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/task/mod.rs:422:9
  368. 58: tokio::runtime::blocking::pool::Task::run
  369. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:111:9
  370. 59: tokio::runtime::blocking::pool::Inner::run
  371. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:346:17
  372. 60: tokio::runtime::blocking::pool::Spawner::spawn_thread::{{closure}}
  373. at /Users/user/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.21.2/src/runtime/blocking/pool.rs:321:13
  374. note: Some details are omitted, run with `RUST_BACKTRACE=full` for a verbose backtrace.
Advertisement
Add Comment
Please, Sign In to add comment