Created
March 7, 2023 15:40
-
-
Save def-/c06fad87b31fb588b00c306138e23230 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Core was generated by `/home/deen/git/materialize3/target/release/clusterd --storage-controller-listen'. | |
| Program terminated with signal SIGABRT, Aborted. | |
| #0 0x00007ff66129226b in pthread_kill () from /lib/x86_64-linux-gnu/libc.so.6 | |
| [Current thread is 1 (Thread 0x7ff6495ff6c0 (LWP 2679964))] | |
| warning: Missing auto-load script at offset 0 in section .debug_gdb_scripts | |
| of file /home/deen/git/materialize3/target/release/clusterd. | |
| Use `info auto-load python-scripts [REGEXP]' to list them. | |
| (gdb) bt | |
| #0 0x00007ff66129226b in pthread_kill () from /lib/x86_64-linux-gnu/libc.so.6 | |
| #1 0x00007ff66123bc46 in raise () from /lib/x86_64-linux-gnu/libc.so.6 | |
| #2 0x00007ff6612227fc in abort () from /lib/x86_64-linux-gnu/libc.so.6 | |
| #3 0x0000563ca0f09407 in std::sys::unix::abort_internal () at library/std/src/sys/unix/mod.rs:350 | |
| #4 0x0000563ca0eff0b7 in std::process::abort () at library/std/src/process.rs:2130 | |
| #5 0x0000563ca080199a in mz_ore::panic::set_abort_on_panic::{closure#0} () at src/ore/src/panic.rs:64 | |
| #6 0x0000563ca0f0316d in alloc::boxed::{impl#47}::call<(&core::panic::panic_info::PanicInfo), (dyn core::ops::function::Fn<(&core::panic::panic_info::PanicInfo), Output=()> + core::marker::Send + core::marker::Sync), alloc::alloc::Global> () at library/alloc/src/boxed.rs:2002 | |
| #7 std::panicking::rust_panic_with_hook () at library/std/src/panicking.rs:696 | |
| #8 0x0000563ca0f02ee9 in std::panicking::begin_panic_handler::{closure#0} () | |
| at library/std/src/panicking.rs:583 | |
| #9 0x0000563ca0f00ea6 in std::sys_common::backtrace::__rust_end_short_backtrace<std::panicking::begin_panic_handler::{closure_env#0}, !> () at library/std/src/sys_common/backtrace.rs:137 | |
| #10 0x0000563ca0f02bf2 in std::panicking::begin_panic_handler () at library/std/src/panicking.rs:579 | |
| #11 0x0000563ca0f2a2e3 in core::panicking::panic_fmt () at library/core/src/panicking.rs:64 | |
| #12 0x0000563ca017ac68 in core::panicking::panic_display<&str> () | |
| at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/panicking.rs:147 | |
| #13 0x0000563ca0181685 in core::time::Duration::from_secs_f64 () | |
| at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/time.rs:742 | |
| #14 mz_expr::scalar::func::impls::float64::sleep () at src/expr/src/scalar/func/impls/float64.rs:430 | |
| #15 0x0000563ca0180ec8 in mz_expr::scalar::func::impls::float64::{impl#420}::call () | |
| at src/expr/src/scalar/func/macros.rs:105 | |
| #16 mz_expr::scalar::func::{impl#7}::eval<mz_expr::scalar::func::impls::float64::Sleep> () | |
| at src/expr/src/scalar/func.rs:3750 | |
| #17 0x0000563ca0164c08 in mz_expr::scalar::func::UnaryFunc::eval () | |
| at src/expr/src/scalar/func/macros.rs:289 | |
| #18 0x0000563ca020c8fe in mz_expr::scalar::MirScalarExpr::eval () at src/expr/src/scalar/mod.rs:1749 | |
| #19 0x0000563ca013d8b0 in mz_expr::scalar::func::BinaryFunc::eval () at src/expr/src/scalar/func.rs:2124 | |
| #20 0x0000563ca020c924 in mz_expr::scalar::MirScalarExpr::eval () at src/expr/src/scalar/mod.rs:1751 | |
| #21 0x0000563ca01c59fc in mz_expr::linear::plan::SafeMfpPlan::evaluate_inner () | |
| at src/expr/src/linear.rs:1532 | |
| #22 0x0000563c9eacabb8 in mz_expr::linear::plan::MfpPlan::evaluate<mz_storage_client::types::errors::DataflowError, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<--Type <RET> for more, q to quit, c to continue without paging-- | |
| timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>> () at src/expr/src/linear.rs:1775 | |
| #23 0x0000563c9daf533a in mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp> () at src/compute/src/render/context.rs:647 | |
| #24 mz_compute::render::context::{impl#7}::flat_map::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>> () | |
| at src/compute/src/render/context.rs:508 | |
| #25 timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp--Type <RET> for more, q to quit, c to continue without paging--c | |
| ::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/map.rs:79 | |
| #26 core::ops::function::impls::{impl#4}::call_once<((mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64)), timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/ops/function.rs:310 | |
| #27 0x0000563c9def802b in core::option::Option::map<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, &mut timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/option.rs:972 | |
| #28 core::iter::adapters::map::{impl#2}::next<core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, alloc::vec::drain::Drain<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/iter/adapters/map.rs:103 | |
| #29 core::iter::adapters::fuse::{impl#9}::next<core::iter::adapters::map::Map<alloc::vec::drain::Drain<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/iter/adapters/fuse.rs:337 | |
| #30 core::iter::adapters::fuse::{impl#2}::next<core::iter::adapters::map::Map<alloc::vec::drain::Drain<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/iter/adapters/fuse.rs:43 | |
| #31 core::iter::adapters::flatten::{impl#19}::next<core::iter::adapters::map::Map<alloc::vec::drain::Drain<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>>, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/iter/adapters/flatten.rs:474 | |
| #32 core::iter::adapters::flatten::{impl#3}::next<alloc::vec::drain::Drain<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/iter/adapters/flatten.rs:51 | |
| #33 timely::dataflow::channels::pushers::buffer::Session::give_iterator<mz_repr::timestamp::Timestamp, core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, timely::dataflow::channels::pushers::counter::CounterCore<mz_repr::timestamp::Timestamp, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::channels::pushers::tee::TeeCore<mz_repr::timestamp::Timestamp, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>>>, core::iter::adapters::flatten::FlatMap<alloc::vec::drain::Drain<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/channels/pushers/buffer.rs:132 | |
| #34 timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/map.rs:79 | |
| #35 timely::dataflow::operators::generic::handles::InputHandleCore::for_each<mz_repr::timestamp::Timestamp, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, timely::dataflow::channels::pact::LogPuller<mz_repr::timestamp::Timestamp, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, timely_communication::allocator::counters::Puller<timely_communication::message::Message<timely::dataflow::channels::Message<mz_repr::timestamp::Timestamp, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>>>, timely_communication::allocator::thread::Puller<timely_communication::message::Message<timely::dataflow::channels::Message<mz_repr::timestamp::Timestamp, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>>>>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/generic/handles.rs:94 | |
| #36 timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/map.rs:77 | |
| #37 timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure#0}::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/generic/operator.rs:401 | |
| #38 timely::dataflow::operators::generic::builder_rc::{impl#0}::build::{closure#0}::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/generic/builder_rc.rs:133 | |
| #39 timely::dataflow::operators::generic::builder_rc::{impl#0}::build_reschedule::{closure#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::builder_rc::{impl#0}::build::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>>, timely::dataflow::operators::generic::builder_rc::{impl#0}::build::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/generic/builder_rc.rs:172 | |
| #40 timely::dataflow::operators::generic::builder_raw::{impl#2}::schedule<mz_repr::timestamp::Timestamp, timely::dataflow::operators::generic::builder_rc::{impl#0}::build_reschedule::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::builder_rc::{impl#0}::build::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>>, timely::dataflow::operators::generic::builder_rc::{impl#0}::build::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>, timely::dataflow::operators::generic::operator::{impl#0}::unary::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, alloc::vec::Vec<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), alloc::alloc::Global>, alloc::vec::Vec<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>, alloc::alloc::Global>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::operators::map::{impl#0}::flat_map::{closure#0}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, (mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#7}::flat_map::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp, core::iter::adapters::map::Map<core::iter::adapters::chain::Chain<core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>, core::option::IntoIter<core::result::Result<(mz_repr::row::Row, mz_repr::timestamp::Timestamp, i64), (mz_storage_client::types::errors::DataflowError, mz_repr::timestamp::Timestamp, i64)>>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure#0}::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>, mz_compute::render::context::{impl#8}::as_collection_core::{closure_env#1}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_compute::render::context::{impl#8}::as_collection_core::{closure#1}::{closure_env#0}<timely::dataflow::scopes::child::Child<timely::dataflow::scopes::child::Child<timely::worker::Worker<timely_communication::allocator::generic::Generic>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>, mz_repr::timestamp::Timestamp>>>, timely::dataflow::channels::pact::Pipeline>>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/dataflow/operators/generic/builder_raw.rs:204 | |
| #41 0x0000563c9dcfa24d in timely::progress::subgraph::PerOperatorState::schedule<mz_repr::timestamp::Timestamp> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/progress/subgraph.rs:699 | |
| #42 0x0000563c9dbb8456 in timely::progress::subgraph::Subgraph::activate_child<mz_repr::timestamp::Timestamp, mz_repr::timestamp::Timestamp> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/progress/subgraph.rs:346 | |
| #43 timely::progress::subgraph::{impl#1}::schedule<mz_repr::timestamp::Timestamp, mz_repr::timestamp::Timestamp> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/progress/subgraph.rs:312 | |
| #44 0x0000563c9dcfa24d in timely::progress::subgraph::PerOperatorState::schedule<mz_repr::timestamp::Timestamp> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/progress/subgraph.rs:699 | |
| #45 0x0000563c9dbb6716 in timely::progress::subgraph::Subgraph::activate_child<(), mz_repr::timestamp::Timestamp> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/progress/subgraph.rs:346 | |
| #46 timely::progress::subgraph::{impl#1}::schedule<(), mz_repr::timestamp::Timestamp> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/progress/subgraph.rs:312 | |
| #47 0x0000563ca046ee0b in timely::worker::{impl#7}::step::{closure#0} () at src/worker.rs:754 | |
| #48 core::option::Option::map<&mut alloc::boxed::Box<dyn timely::scheduling::Schedule, alloc::alloc::Global>, bool, timely::worker::{impl#7}::step::{closure_env#0}> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/option.rs:972 | |
| #49 timely::worker::Wrapper::step () at src/worker.rs:754 | |
| #50 0x0000563c9efb77c0 in timely::worker::Worker::step_or_park<timely_communication::allocator::generic::Generic> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/worker.rs:396 | |
| #51 0x0000563c9eee808e in mz_compute::server::Worker::run_client<timely_communication::allocator::generic::Generic> () at src/compute/src/server.rs:347 | |
| #52 mz_compute::server::Worker::setup_channel_and_run_client<timely_communication::allocator::generic::Generic> () at src/compute/src/server.rs:321 | |
| #53 0x0000563c9ef2c262 in mz_compute::server::Worker::run<timely_communication::allocator::generic::Generic> () at src/compute/src/server.rs:181 | |
| #54 mz_compute::server::{impl#1}::build_and_run<timely_communication::allocator::generic::Generic> () at src/compute/src/server.rs:162 | |
| #55 mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>> () at src/cluster/src/server.rs:178 | |
| #56 timely::execute::execute_from::{closure#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/timely/src/execute.rs:388 | |
| #57 timely_communication::initialize::initialize_from::{closure#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>> () at /home/deen/.cargo/git/checkouts/timely-dataflow-4c0cc365061cd263/f2ea960/communication/src/initialize.rs:316 | |
| #58 std::sys_common::backtrace::__rust_begin_short_backtrace<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/std/src/sys_common/backtrace.rs:121 | |
| #59 0x0000563c9daf7ef7 in std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure#0}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/std/src/thread/mod.rs:560 | |
| #60 core::panic::unwind_safe::{impl#23}::call_once<(), std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/panic/unwind_safe.rs:271 | |
| #61 std::panicking::try::do_call<core::panic::unwind_safe::AssertUnwindSafe<std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()>>, ()> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/std/src/panicking.rs:487 | |
| #62 std::panicking::try<(), core::panic::unwind_safe::AssertUnwindSafe<std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()>>> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/std/src/panicking.rs:451 | |
| #63 std::panic::catch_unwind<core::panic::unwind_safe::AssertUnwindSafe<std::thread::{impl#0}::spawn_unchecked_::{closure#1}::{closure_env#0}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()>>, ()> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/std/src/panic.rs:140 | |
| #64 std::thread::{impl#0}::spawn_unchecked_::{closure#1}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/std/src/thread/mod.rs:559 | |
| #65 core::ops::function::FnOnce::call_once<std::thread::{impl#0}::spawn_unchecked_::{closure_env#1}<timely_communication::initialize::initialize_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), timely::execute::execute_from::{closure_env#0}<timely_communication::allocator::generic::GenericBuilder, (), mz_cluster::server::{impl#0}::build_timely::{async_fn#0}::{closure_env#1}<mz_compute::server::Config, mz_compute_client::protocol::command::ComputeCommand<mz_repr::timestamp::Timestamp>, mz_compute_client::protocol::response::ComputeResponse<mz_repr::timestamp::Timestamp>>>>, ()>, ()> () at /rustc/fdbc4329cb781c7768ffa6d76c8fa2d032d3fe20/library/core/src/ops/function.rs:250 | |
| #66 0x0000563ca0f08d53 in alloc::boxed::{impl#45}::call_once<(), dyn core::ops::function::FnOnce<(), Output=()>, alloc::alloc::Global> () at library/alloc/src/boxed.rs:1988 | |
| #67 alloc::boxed::{impl#45}::call_once<(), alloc::boxed::Box<dyn core::ops::function::FnOnce<(), Output=()>, alloc::alloc::Global>, alloc::alloc::Global> () at library/alloc/src/boxed.rs:1988 | |
| #68 std::sys::unix::thread::{impl#2}::new::thread_start () at library/std/src/sys/unix/thread.rs:108 | |
| #69 0x00007ff661290402 in ?? () from /lib/x86_64-linux-gnu/libc.so.6 | |
| #70 0x00007ff66131f590 in ?? () from /lib/x86_64-linux-gnu/libc.so.6 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment