[INFO] fetching crate erdos 0.4.0... [INFO] checking erdos-0.4.0 against try#f6d7c613ae2d161ff37dbc63cc5abd809c878597 for pr-83850 [INFO] extracting crate erdos 0.4.0 into /workspace/builds/worker-7/source [INFO] validating manifest of crates.io crate erdos 0.4.0 on toolchain f6d7c613ae2d161ff37dbc63cc5abd809c878597 [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f6d7c613ae2d161ff37dbc63cc5abd809c878597" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] started tweaking crates.io crate erdos 0.4.0 [INFO] finished tweaking crates.io crate erdos 0.4.0 [INFO] tweaked toml for crates.io crate erdos 0.4.0 written to /workspace/builds/worker-7/source/Cargo.toml [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f6d7c613ae2d161ff37dbc63cc5abd809c878597" "generate-lockfile" "--manifest-path" "Cargo.toml" "-Zno-index-update", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+f6d7c613ae2d161ff37dbc63cc5abd809c878597" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Blocking waiting for file lock on package cache [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:ac0d0aa6ec8ed129e241004a6179c99fa0d2616f50ba759c5b60bd26d0fafa02" "/opt/rustwide/cargo-home/bin/cargo" "+f6d7c613ae2d161ff37dbc63cc5abd809c878597" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 5e6c65eed07fe7e7cb916a212be1d05bb886c6a990fcbdb183e550122e60a35b [INFO] running `Command { std: "docker" "start" "-a" "5e6c65eed07fe7e7cb916a212be1d05bb886c6a990fcbdb183e550122e60a35b", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "5e6c65eed07fe7e7cb916a212be1d05bb886c6a990fcbdb183e550122e60a35b", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "5e6c65eed07fe7e7cb916a212be1d05bb886c6a990fcbdb183e550122e60a35b", kill_on_drop: false }` [INFO] [stdout] 5e6c65eed07fe7e7cb916a212be1d05bb886c6a990fcbdb183e550122e60a35b [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-7/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-7/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:ac0d0aa6ec8ed129e241004a6179c99fa0d2616f50ba759c5b60bd26d0fafa02" "/opt/rustwide/cargo-home/bin/cargo" "+f6d7c613ae2d161ff37dbc63cc5abd809c878597" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 52951ea4078724eec3d23268d1185b61f8dd6980628b19e26381a180ddaa0007 [INFO] running `Command { std: "docker" "start" "-a" "52951ea4078724eec3d23268d1185b61f8dd6980628b19e26381a180ddaa0007", kill_on_drop: false }` [INFO] [stderr] Compiling proc-macro2 v1.0.40 [INFO] [stderr] Compiling unicode-ident v1.0.1 [INFO] [stderr] Compiling quote v1.0.20 [INFO] [stderr] Compiling syn v1.0.98 [INFO] [stderr] Compiling libc v0.2.126 [INFO] [stderr] Compiling autocfg v1.1.0 [INFO] [stderr] Checking cfg-if v1.0.0 [INFO] [stderr] Compiling version_check v0.9.4 [INFO] [stderr] Checking once_cell v1.12.0 [INFO] [stderr] Compiling futures-core v0.3.21 [INFO] [stderr] Compiling memchr v2.5.0 [INFO] [stderr] Compiling log v0.4.17 [INFO] [stderr] Checking pin-project-lite v0.2.9 [INFO] [stderr] Checking smallvec v1.8.0 [INFO] [stderr] Checking futures-io v0.3.21 [INFO] [stderr] Checking rand_core v0.4.2 [INFO] [stderr] Checking cache-padded v1.2.0 [INFO] [stderr] Checking slab v0.4.6 [INFO] [stderr] Checking waker-fn v1.1.0 [INFO] [stderr] Checking fastrand v1.7.0 [INFO] [stderr] Checking scopeguard v1.1.0 [INFO] [stderr] Checking parking v2.0.0 [INFO] [stderr] Compiling crossbeam-utils v0.8.9 [INFO] [stderr] Compiling serde_derive v1.0.137 [INFO] [stderr] Checking event-listener v2.5.2 [INFO] [stderr] Compiling parking_lot_core v0.8.5 [INFO] [stderr] Compiling futures-channel v0.3.21 [INFO] [stderr] Checking pin-utils v0.1.0 [INFO] [stderr] Checking async-task v4.2.0 [INFO] [stderr] Compiling serde v1.0.137 [INFO] [stderr] Checking futures-sink v0.3.21 [INFO] [stderr] Compiling parking_lot_core v0.9.3 [INFO] [stderr] Compiling futures-task v0.3.21 [INFO] [stderr] Compiling futures-util v0.3.21 [INFO] [stderr] Checking lazy_static v1.4.0 [INFO] [stderr] Checking atomic-waker v1.0.0 [INFO] [stderr] Checking byteorder v1.4.3 [INFO] [stderr] Checking ansi_term v0.12.1 [INFO] [stderr] Checking bytes v1.1.0 [INFO] [stderr] Checking hashbrown v0.12.1 [INFO] [stderr] Checking futures v0.1.31 [INFO] [stderr] Checking num_threads v0.1.6 [INFO] [stderr] Checking unicode-width v0.1.9 [INFO] [stderr] Compiling unicode-xid v0.2.3 [INFO] [stderr] Compiling async-trait v0.1.56 [INFO] [stderr] Checking sha1_smol v1.0.0 [INFO] [stderr] Checking itoa v1.0.2 [INFO] [stderr] Checking vec_map v0.8.2 [INFO] [stderr] Checking strsim v0.8.0 [INFO] [stderr] Checking futures-timer v3.0.2 [INFO] [stderr] Checking fixedbitset v0.2.0 [INFO] [stderr] Checking bitflags v1.3.2 [INFO] [stderr] Checking abomonation v0.7.3 [INFO] [stderr] Checking instant v0.1.12 [INFO] [stderr] Compiling autocfg v0.1.8 [INFO] [stderr] Checking concurrent-queue v1.2.2 [INFO] [stderr] Checking rand_core v0.3.1 [INFO] [stderr] Checking tracing-core v0.1.27 [INFO] [stderr] Checking rand_jitter v0.1.4 [INFO] [stderr] Checking thread_local v1.1.4 [INFO] [stderr] Compiling value-bag v1.0.0-alpha.9 [INFO] [stderr] Compiling lock_api v0.4.7 [INFO] [stderr] Compiling indexmap v1.9.0 [INFO] [stderr] Checking async-lock v2.5.0 [INFO] [stderr] Checking sharded-slab v0.1.4 [INFO] [stderr] Checking textwrap v0.11.0 [INFO] [stderr] Checking sha1 v0.6.1 [INFO] [stderr] Compiling rand_pcg v0.1.2 [INFO] [stderr] Compiling rand_chacha v0.1.1 [INFO] [stderr] Compiling rand v0.6.5 [INFO] [stderr] Checking rand_xorshift v0.1.1 [INFO] [stderr] Checking rand_hc v0.1.0 [INFO] [stderr] Checking rand_isaac v0.1.1 [INFO] [stderr] Checking crossbeam-channel v0.5.5 [INFO] [stderr] Checking async-channel v1.6.1 [INFO] [stderr] Checking futures-lite v1.12.0 [INFO] [stderr] Checking socket2 v0.4.4 [INFO] [stderr] Checking num_cpus v1.13.1 [INFO] [stderr] Checking iovec v0.1.4 [INFO] [stderr] Checking signal-hook-registry v1.4.0 [INFO] [stderr] Checking rand_os v0.1.3 [INFO] [stderr] Checking time v0.3.10 [INFO] [stderr] Checking atty v0.2.14 [INFO] [stderr] Checking rand v0.4.6 [INFO] [stderr] Checking bytes v0.4.12 [INFO] [stderr] Checking petgraph v0.5.1 [INFO] [stderr] Checking clap v2.34.0 [INFO] [stderr] Checking parking_lot v0.11.2 [INFO] [stderr] Checking async-executor v1.4.1 [INFO] [stderr] Checking blocking v1.2.0 [INFO] [stderr] Checking parking_lot v0.12.1 [INFO] [stderr] Checking tokio-serde v0.3.0 [INFO] [stderr] Checking rand v0.3.23 [INFO] [stderr] Checking futures-intrusive v0.4.0 [INFO] [stderr] Compiling synstructure v0.12.6 [INFO] [stderr] Compiling ctor v0.1.22 [INFO] [stderr] Compiling futures-macro v0.3.21 [INFO] [stderr] Compiling tokio-macros v1.8.0 [INFO] [stderr] Compiling tracing-attributes v0.1.21 [INFO] [stderr] Compiling abomonation_derive v0.5.0 [INFO] [stderr] Checking polling v2.2.0 [INFO] [stderr] Checking tracing-log v0.1.3 [INFO] [stderr] Checking mio v0.8.4 [INFO] [stderr] Checking kv-log-macro v1.0.7 [INFO] [stderr] Checking tracing-subscriber v0.3.11 [INFO] [stderr] Checking async-io v1.7.0 [INFO] [stderr] Checking async-global-executor v2.2.0 [INFO] [stderr] Checking tokio v1.19.2 [INFO] [stderr] Checking tracing-appender v0.2.2 [INFO] [stderr] Checking async-std v1.12.0 [INFO] [stderr] Checking tracing v0.1.35 [INFO] [stderr] Checking futures-delay-queue v0.4.2 [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Checking uuid v0.7.4 [INFO] [stderr] Checking futures-executor v0.3.21 [INFO] [stderr] Checking tokio-util v0.6.10 [INFO] [stderr] Checking tokio-serde-bincode v0.2.1 [INFO] [stderr] Checking futures v0.3.21 [INFO] [stderr] Checking erdos v0.4.0 (/opt/rustwide/workdir) [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:132:68 [INFO] [stdout] | [INFO] [stdout] 132 | &ParallelOneInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ------------------------------- ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:192:8 [INFO] [stdout] | [INFO] [stdout] 192 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 195 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:132:68 [INFO] [stdout] | [INFO] [stdout] 132 | &ParallelOneInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ------------------------------- ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:192:8 [INFO] [stdout] | [INFO] [stdout] 192 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 195 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:132:22 [INFO] [stdout] | [INFO] [stdout] 132 | &ParallelOneInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:180:8 [INFO] [stdout] | [INFO] [stdout] 178 | pub struct ParallelOneInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 179 | where [INFO] [stdout] 180 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:132:22 [INFO] [stdout] | [INFO] [stdout] 132 | &ParallelOneInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:180:8 [INFO] [stdout] | [INFO] [stdout] 178 | pub struct ParallelOneInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 179 | where [INFO] [stdout] 180 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:132:21 [INFO] [stdout] | [INFO] [stdout] 73 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 131 | operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 132 | &ParallelOneInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelOneInOneOutContext<'_, S, U, V>` [INFO] [stdout] found reference `&context::ParallelOneInOneOutContext<'_, Arc, U, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:116:8 [INFO] [stdout] | [INFO] [stdout] 116 | fn on_data(&self, ctx: &ParallelOneInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:162:25 [INFO] [stdout] | [INFO] [stdout] 159 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 162 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:192:8 [INFO] [stdout] | [INFO] [stdout] 192 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 195 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:159:48 [INFO] [stdout] | [INFO] [stdout] 159 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 160 | | time, [INFO] [stdout] 161 | | config, [INFO] [stdout] 162 | | &state, [INFO] [stdout] 163 | | write_stream, [INFO] [stdout] 164 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:180:8 [INFO] [stdout] | [INFO] [stdout] 178 | pub struct ParallelOneInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 179 | where [INFO] [stdout] 180 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:132:21 [INFO] [stdout] | [INFO] [stdout] 73 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 131 | operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 132 | &ParallelOneInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelOneInOneOutContext<'_, S, U, V>` [INFO] [stdout] found reference `&context::ParallelOneInOneOutContext<'_, Arc, U, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:116:8 [INFO] [stdout] | [INFO] [stdout] 116 | fn on_data(&self, ctx: &ParallelOneInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:162:25 [INFO] [stdout] | [INFO] [stdout] 159 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 162 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:192:8 [INFO] [stdout] | [INFO] [stdout] 192 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 195 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:159:48 [INFO] [stdout] | [INFO] [stdout] 159 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 160 | | time, [INFO] [stdout] 161 | | config, [INFO] [stdout] 162 | | &state, [INFO] [stdout] 163 | | write_stream, [INFO] [stdout] 164 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:180:8 [INFO] [stdout] | [INFO] [stdout] 178 | pub struct ParallelOneInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 179 | where [INFO] [stdout] 180 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:159:43 [INFO] [stdout] | [INFO] [stdout] 73 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 159 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 160 | | time, [INFO] [stdout] 161 | | config, [INFO] [stdout] 162 | | &state, [INFO] [stdout] 163 | | write_stream, [INFO] [stdout] 164 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInOneOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInOneOutContext<'_, Arc, U, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:118:8 [INFO] [stdout] | [INFO] [stdout] 118 | fn on_watermark(&self, ctx: &mut ParallelOneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:188:25 [INFO] [stdout] | [INFO] [stdout] 185 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 188 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:192:8 [INFO] [stdout] | [INFO] [stdout] 192 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 195 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:185:48 [INFO] [stdout] | [INFO] [stdout] 185 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 186 | | time.clone(), [INFO] [stdout] 187 | | config, [INFO] [stdout] 188 | | &state, [INFO] [stdout] 189 | | write_stream, [INFO] [stdout] 190 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:180:8 [INFO] [stdout] | [INFO] [stdout] 178 | pub struct ParallelOneInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 179 | where [INFO] [stdout] 180 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:159:43 [INFO] [stdout] | [INFO] [stdout] 73 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 159 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 160 | | time, [INFO] [stdout] 161 | | config, [INFO] [stdout] 162 | | &state, [INFO] [stdout] 163 | | write_stream, [INFO] [stdout] 164 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInOneOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInOneOutContext<'_, Arc, U, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:118:8 [INFO] [stdout] | [INFO] [stdout] 118 | fn on_watermark(&self, ctx: &mut ParallelOneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:188:25 [INFO] [stdout] | [INFO] [stdout] 185 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 188 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:192:8 [INFO] [stdout] | [INFO] [stdout] 192 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 195 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:185:48 [INFO] [stdout] | [INFO] [stdout] 185 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 186 | | time.clone(), [INFO] [stdout] 187 | | config, [INFO] [stdout] 188 | | &state, [INFO] [stdout] 189 | | write_stream, [INFO] [stdout] 190 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:180:8 [INFO] [stdout] | [INFO] [stdout] 178 | pub struct ParallelOneInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 179 | where [INFO] [stdout] 180 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:185:43 [INFO] [stdout] | [INFO] [stdout] 73 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 185 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 186 | | time.clone(), [INFO] [stdout] 187 | | config, [INFO] [stdout] 188 | | &state, [INFO] [stdout] 189 | | write_stream, [INFO] [stdout] 190 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInOneOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInOneOutContext<'_, Arc, U, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:118:8 [INFO] [stdout] | [INFO] [stdout] 118 | fn on_watermark(&self, ctx: &mut ParallelOneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:356:64 [INFO] [stdout] | [INFO] [stdout] 356 | &mut OneInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ----------------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:252:8 [INFO] [stdout] | [INFO] [stdout] 252 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 255 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:356:26 [INFO] [stdout] | [INFO] [stdout] 356 | &mut OneInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:241:8 [INFO] [stdout] | [INFO] [stdout] 239 | pub struct OneInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 240 | where [INFO] [stdout] 241 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:185:43 [INFO] [stdout] | [INFO] [stdout] 73 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 185 | operator.on_watermark(&mut ParallelOneInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 186 | | time.clone(), [INFO] [stdout] 187 | | config, [INFO] [stdout] 188 | | &state, [INFO] [stdout] 189 | | write_stream, [INFO] [stdout] 190 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInOneOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInOneOutContext<'_, Arc, U, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:118:8 [INFO] [stdout] | [INFO] [stdout] 118 | fn on_watermark(&self, ctx: &mut ParallelOneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:356:64 [INFO] [stdout] | [INFO] [stdout] 356 | &mut OneInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ----------------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:252:8 [INFO] [stdout] | [INFO] [stdout] 252 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 255 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:356:26 [INFO] [stdout] | [INFO] [stdout] 356 | &mut OneInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:241:8 [INFO] [stdout] | [INFO] [stdout] 239 | pub struct OneInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 240 | where [INFO] [stdout] 241 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:356:21 [INFO] [stdout] | [INFO] [stdout] 298 | impl OneInMessageProcessorT for OneInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 355 | mutable_operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 356 | &mut OneInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInOneOutContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::OneInOneOutContext<'_, std::sync::MutexGuard<'_, S>, U>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:152:8 [INFO] [stdout] | [INFO] [stdout] 152 | fn on_data(&mut self, ctx: &mut OneInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:389:25 [INFO] [stdout] | [INFO] [stdout] 386 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 389 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:252:8 [INFO] [stdout] | [INFO] [stdout] 252 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 255 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:386:56 [INFO] [stdout] | [INFO] [stdout] 386 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 387 | | time, [INFO] [stdout] 388 | | config, [INFO] [stdout] 389 | | &mut mutable_state, [INFO] [stdout] 390 | | write_stream, [INFO] [stdout] 391 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:241:8 [INFO] [stdout] | [INFO] [stdout] 239 | pub struct OneInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 240 | where [INFO] [stdout] 241 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:356:21 [INFO] [stdout] | [INFO] [stdout] 298 | impl OneInMessageProcessorT for OneInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 355 | mutable_operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 356 | &mut OneInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInOneOutContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::OneInOneOutContext<'_, std::sync::MutexGuard<'_, S>, U>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:152:8 [INFO] [stdout] | [INFO] [stdout] 152 | fn on_data(&mut self, ctx: &mut OneInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:389:25 [INFO] [stdout] | [INFO] [stdout] 386 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 389 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:252:8 [INFO] [stdout] | [INFO] [stdout] 252 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 255 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:386:56 [INFO] [stdout] | [INFO] [stdout] 386 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 387 | | time, [INFO] [stdout] 388 | | config, [INFO] [stdout] 389 | | &mut mutable_state, [INFO] [stdout] 390 | | write_stream, [INFO] [stdout] 391 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:241:8 [INFO] [stdout] | [INFO] [stdout] 239 | pub struct OneInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 240 | where [INFO] [stdout] 241 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:386:51 [INFO] [stdout] | [INFO] [stdout] 298 | impl OneInMessageProcessorT for OneInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 386 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 387 | | time, [INFO] [stdout] 388 | | config, [INFO] [stdout] 389 | | &mut mutable_state, [INFO] [stdout] 390 | | write_stream, [INFO] [stdout] 391 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInOneOutContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::OneInOneOutContext<'_, std::sync::MutexGuard<'_, S>, U>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:154:8 [INFO] [stdout] | [INFO] [stdout] 154 | fn on_watermark(&mut self, ctx: &mut OneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:418:25 [INFO] [stdout] | [INFO] [stdout] 415 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 418 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:252:8 [INFO] [stdout] | [INFO] [stdout] 252 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 255 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:415:56 [INFO] [stdout] | [INFO] [stdout] 415 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 416 | | time.clone(), [INFO] [stdout] 417 | | config, [INFO] [stdout] 418 | | &mut mutable_state, [INFO] [stdout] 419 | | write_stream, [INFO] [stdout] 420 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:241:8 [INFO] [stdout] | [INFO] [stdout] 239 | pub struct OneInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 240 | where [INFO] [stdout] 241 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:386:51 [INFO] [stdout] | [INFO] [stdout] 298 | impl OneInMessageProcessorT for OneInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 386 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 387 | | time, [INFO] [stdout] 388 | | config, [INFO] [stdout] 389 | | &mut mutable_state, [INFO] [stdout] 390 | | write_stream, [INFO] [stdout] 391 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInOneOutContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::OneInOneOutContext<'_, std::sync::MutexGuard<'_, S>, U>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:154:8 [INFO] [stdout] | [INFO] [stdout] 154 | fn on_watermark(&mut self, ctx: &mut OneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:418:25 [INFO] [stdout] | [INFO] [stdout] 415 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 418 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:252:8 [INFO] [stdout] | [INFO] [stdout] 252 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 255 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:415:56 [INFO] [stdout] | [INFO] [stdout] 415 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 416 | | time.clone(), [INFO] [stdout] 417 | | config, [INFO] [stdout] 418 | | &mut mutable_state, [INFO] [stdout] 419 | | write_stream, [INFO] [stdout] 420 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:241:8 [INFO] [stdout] | [INFO] [stdout] 239 | pub struct OneInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 240 | where [INFO] [stdout] 241 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:415:51 [INFO] [stdout] | [INFO] [stdout] 298 | impl OneInMessageProcessorT for OneInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 415 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 416 | | time.clone(), [INFO] [stdout] 417 | | config, [INFO] [stdout] 418 | | &mut mutable_state, [INFO] [stdout] 419 | | write_stream, [INFO] [stdout] 420 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInOneOutContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::OneInOneOutContext<'_, std::sync::MutexGuard<'_, S>, U>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:154:8 [INFO] [stdout] | [INFO] [stdout] 154 | fn on_watermark(&mut self, ctx: &mut OneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:158:25 [INFO] [stdout] | [INFO] [stdout] 155 | &ParallelOneInTwoOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 158 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] --> src/dataflow/context.rs:476:8 [INFO] [stdout] | [INFO] [stdout] 476 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] ... [INFO] [stdout] 480 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:155:22 [INFO] [stdout] | [INFO] [stdout] 155 | &ParallelOneInTwoOutContext::new( [INFO] [stdout] | ______________________^ [INFO] [stdout] 156 | | time, [INFO] [stdout] 157 | | config, [INFO] [stdout] 158 | | &state, [INFO] [stdout] 159 | | left_write_stream, [INFO] [stdout] 160 | | right_write_stream, [INFO] [stdout] 161 | | ), [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:462:8 [INFO] [stdout] | [INFO] [stdout] 460 | pub struct ParallelOneInTwoOutContext<'a, S, T, U, V> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 461 | where [INFO] [stdout] 462 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_one_out_executor.rs:415:51 [INFO] [stdout] | [INFO] [stdout] 298 | impl OneInMessageProcessorT for OneInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 415 | mutable_operator.on_watermark(&mut OneInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 416 | | time.clone(), [INFO] [stdout] 417 | | config, [INFO] [stdout] 418 | | &mut mutable_state, [INFO] [stdout] 419 | | write_stream, [INFO] [stdout] 420 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInOneOutContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::OneInOneOutContext<'_, std::sync::MutexGuard<'_, S>, U>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:154:8 [INFO] [stdout] | [INFO] [stdout] 154 | fn on_watermark(&mut self, ctx: &mut OneInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:158:25 [INFO] [stdout] | [INFO] [stdout] 155 | &ParallelOneInTwoOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 158 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] --> src/dataflow/context.rs:476:8 [INFO] [stdout] | [INFO] [stdout] 476 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] ... [INFO] [stdout] 480 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:155:22 [INFO] [stdout] | [INFO] [stdout] 155 | &ParallelOneInTwoOutContext::new( [INFO] [stdout] | ______________________^ [INFO] [stdout] 156 | | time, [INFO] [stdout] 157 | | config, [INFO] [stdout] 158 | | &state, [INFO] [stdout] 159 | | left_write_stream, [INFO] [stdout] 160 | | right_write_stream, [INFO] [stdout] 161 | | ), [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:462:8 [INFO] [stdout] | [INFO] [stdout] 460 | pub struct ParallelOneInTwoOutContext<'a, S, T, U, V> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 461 | where [INFO] [stdout] 462 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:155:21 [INFO] [stdout] | [INFO] [stdout] 79 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 154 | operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 155 | / &ParallelOneInTwoOutContext::new( [INFO] [stdout] 156 | | time, [INFO] [stdout] 157 | | config, [INFO] [stdout] 158 | | &state, [INFO] [stdout] 159 | | left_write_stream, [INFO] [stdout] 160 | | right_write_stream, [INFO] [stdout] 161 | | ), [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelOneInTwoOutContext<'_, S, U, V, W>` [INFO] [stdout] found reference `&context::ParallelOneInTwoOutContext<'_, Arc, U, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:278:8 [INFO] [stdout] | [INFO] [stdout] 278 | fn on_data(&self, ctx: &ParallelOneInTwoOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:195:25 [INFO] [stdout] | [INFO] [stdout] 192 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 195 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] --> src/dataflow/context.rs:476:8 [INFO] [stdout] | [INFO] [stdout] 476 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] ... [INFO] [stdout] 480 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:192:48 [INFO] [stdout] | [INFO] [stdout] 192 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 193 | | time, [INFO] [stdout] 194 | | config, [INFO] [stdout] 195 | | &state, [INFO] [stdout] 196 | | left_write_stream, [INFO] [stdout] 197 | | right_write_stream, [INFO] [stdout] 198 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:462:8 [INFO] [stdout] | [INFO] [stdout] 460 | pub struct ParallelOneInTwoOutContext<'a, S, T, U, V> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 461 | where [INFO] [stdout] 462 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:155:21 [INFO] [stdout] | [INFO] [stdout] 79 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 154 | operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 155 | / &ParallelOneInTwoOutContext::new( [INFO] [stdout] 156 | | time, [INFO] [stdout] 157 | | config, [INFO] [stdout] 158 | | &state, [INFO] [stdout] 159 | | left_write_stream, [INFO] [stdout] 160 | | right_write_stream, [INFO] [stdout] 161 | | ), [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelOneInTwoOutContext<'_, S, U, V, W>` [INFO] [stdout] found reference `&context::ParallelOneInTwoOutContext<'_, Arc, U, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:278:8 [INFO] [stdout] | [INFO] [stdout] 278 | fn on_data(&self, ctx: &ParallelOneInTwoOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:195:25 [INFO] [stdout] | [INFO] [stdout] 192 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 195 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] --> src/dataflow/context.rs:476:8 [INFO] [stdout] | [INFO] [stdout] 476 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] ... [INFO] [stdout] 480 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:192:48 [INFO] [stdout] | [INFO] [stdout] 192 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 193 | | time, [INFO] [stdout] 194 | | config, [INFO] [stdout] 195 | | &state, [INFO] [stdout] 196 | | left_write_stream, [INFO] [stdout] 197 | | right_write_stream, [INFO] [stdout] 198 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:462:8 [INFO] [stdout] | [INFO] [stdout] 460 | pub struct ParallelOneInTwoOutContext<'a, S, T, U, V> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 461 | where [INFO] [stdout] 462 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:192:43 [INFO] [stdout] | [INFO] [stdout] 79 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 192 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 193 | | time, [INFO] [stdout] 194 | | config, [INFO] [stdout] 195 | | &state, [INFO] [stdout] 196 | | left_write_stream, [INFO] [stdout] 197 | | right_write_stream, [INFO] [stdout] 198 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInTwoOutContext<'_, S, U, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInTwoOutContext<'_, Arc, U, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:280:8 [INFO] [stdout] | [INFO] [stdout] 280 | fn on_watermark(&self, ctx: &mut ParallelOneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:225:25 [INFO] [stdout] | [INFO] [stdout] 222 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 225 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] --> src/dataflow/context.rs:476:8 [INFO] [stdout] | [INFO] [stdout] 476 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] ... [INFO] [stdout] 480 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:222:48 [INFO] [stdout] | [INFO] [stdout] 222 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 223 | | time.clone(), [INFO] [stdout] 224 | | config, [INFO] [stdout] 225 | | &state, [INFO] [stdout] 226 | | left_write_stream, [INFO] [stdout] 227 | | right_write_stream, [INFO] [stdout] 228 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:462:8 [INFO] [stdout] | [INFO] [stdout] 460 | pub struct ParallelOneInTwoOutContext<'a, S, T, U, V> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 461 | where [INFO] [stdout] 462 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:192:43 [INFO] [stdout] | [INFO] [stdout] 79 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 192 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 193 | | time, [INFO] [stdout] 194 | | config, [INFO] [stdout] 195 | | &state, [INFO] [stdout] 196 | | left_write_stream, [INFO] [stdout] 197 | | right_write_stream, [INFO] [stdout] 198 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInTwoOutContext<'_, S, U, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInTwoOutContext<'_, Arc, U, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:280:8 [INFO] [stdout] | [INFO] [stdout] 280 | fn on_watermark(&self, ctx: &mut ParallelOneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:225:25 [INFO] [stdout] | [INFO] [stdout] 222 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 225 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] --> src/dataflow/context.rs:476:8 [INFO] [stdout] | [INFO] [stdout] 476 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext::<'a, S, T, U, V>::new` [INFO] [stdout] ... [INFO] [stdout] 480 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:222:48 [INFO] [stdout] | [INFO] [stdout] 222 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 223 | | time.clone(), [INFO] [stdout] 224 | | config, [INFO] [stdout] 225 | | &state, [INFO] [stdout] 226 | | left_write_stream, [INFO] [stdout] 227 | | right_write_stream, [INFO] [stdout] 228 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:462:8 [INFO] [stdout] | [INFO] [stdout] 460 | pub struct ParallelOneInTwoOutContext<'a, S, T, U, V> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 461 | where [INFO] [stdout] 462 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelOneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:222:43 [INFO] [stdout] | [INFO] [stdout] 79 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 222 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 223 | | time.clone(), [INFO] [stdout] 224 | | config, [INFO] [stdout] 225 | | &state, [INFO] [stdout] 226 | | left_write_stream, [INFO] [stdout] 227 | | right_write_stream, [INFO] [stdout] 228 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInTwoOutContext<'_, S, U, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInTwoOutContext<'_, Arc, U, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:280:8 [INFO] [stdout] | [INFO] [stdout] 280 | fn on_watermark(&self, ctx: &mut ParallelOneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:222:43 [INFO] [stdout] | [INFO] [stdout] 79 | impl OneInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 222 | operator.on_watermark(&mut ParallelOneInTwoOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 223 | | time.clone(), [INFO] [stdout] 224 | | config, [INFO] [stdout] 225 | | &state, [INFO] [stdout] 226 | | left_write_stream, [INFO] [stdout] 227 | | right_write_stream, [INFO] [stdout] 228 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelOneInTwoOutContext<'_, S, U, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelOneInTwoOutContext<'_, Arc, U, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:280:8 [INFO] [stdout] | [INFO] [stdout] 280 | fn on_watermark(&self, ctx: &mut ParallelOneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:431:25 [INFO] [stdout] | [INFO] [stdout] 428 | &mut OneInTwoOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 431 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:546:8 [INFO] [stdout] | [INFO] [stdout] 546 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 550 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:428:26 [INFO] [stdout] | [INFO] [stdout] 428 | &mut OneInTwoOutContext::new( [INFO] [stdout] | __________________________^ [INFO] [stdout] 429 | | time, [INFO] [stdout] 430 | | config, [INFO] [stdout] 431 | | &mut mutable_state, [INFO] [stdout] 432 | | left_write_stream, [INFO] [stdout] 433 | | right_write_stream, [INFO] [stdout] 434 | | ), [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:533:8 [INFO] [stdout] | [INFO] [stdout] 531 | pub struct OneInTwoOutContext<'a, S, T, U> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 532 | where [INFO] [stdout] 533 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:431:25 [INFO] [stdout] | [INFO] [stdout] 428 | &mut OneInTwoOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 431 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:546:8 [INFO] [stdout] | [INFO] [stdout] 546 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 550 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:428:26 [INFO] [stdout] | [INFO] [stdout] 428 | &mut OneInTwoOutContext::new( [INFO] [stdout] | __________________________^ [INFO] [stdout] 429 | | time, [INFO] [stdout] 430 | | config, [INFO] [stdout] 431 | | &mut mutable_state, [INFO] [stdout] 432 | | left_write_stream, [INFO] [stdout] 433 | | right_write_stream, [INFO] [stdout] 434 | | ), [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:533:8 [INFO] [stdout] | [INFO] [stdout] 531 | pub struct OneInTwoOutContext<'a, S, T, U> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 532 | where [INFO] [stdout] 533 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:428:21 [INFO] [stdout] | [INFO] [stdout] 352 | impl OneInMessageProcessorT for OneInTwoOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 427 | mutable_operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 428 | / &mut OneInTwoOutContext::new( [INFO] [stdout] 429 | | time, [INFO] [stdout] 430 | | config, [INFO] [stdout] 431 | | &mut mutable_state, [INFO] [stdout] 432 | | left_write_stream, [INFO] [stdout] 433 | | right_write_stream, [INFO] [stdout] 434 | | ), [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInTwoOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::OneInTwoOutContext<'_, std::sync::MutexGuard<'_, S>, U, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:316:8 [INFO] [stdout] | [INFO] [stdout] 316 | fn on_data(&mut self, ctx: &mut OneInTwoOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:428:21 [INFO] [stdout] | [INFO] [stdout] 352 | impl OneInMessageProcessorT for OneInTwoOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 427 | mutable_operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 428 | / &mut OneInTwoOutContext::new( [INFO] [stdout] 429 | | time, [INFO] [stdout] 430 | | config, [INFO] [stdout] 431 | | &mut mutable_state, [INFO] [stdout] 432 | | left_write_stream, [INFO] [stdout] 433 | | right_write_stream, [INFO] [stdout] 434 | | ), [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInTwoOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::OneInTwoOutContext<'_, std::sync::MutexGuard<'_, S>, U, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:316:8 [INFO] [stdout] | [INFO] [stdout] 316 | fn on_data(&mut self, ctx: &mut OneInTwoOutContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:471:25 [INFO] [stdout] | [INFO] [stdout] 468 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 471 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:546:8 [INFO] [stdout] | [INFO] [stdout] 546 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 550 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:468:56 [INFO] [stdout] | [INFO] [stdout] 468 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 469 | | time, [INFO] [stdout] 470 | | config, [INFO] [stdout] 471 | | &mut mutable_state, [INFO] [stdout] 472 | | left_write_stream, [INFO] [stdout] 473 | | right_write_stream, [INFO] [stdout] 474 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:533:8 [INFO] [stdout] | [INFO] [stdout] 531 | pub struct OneInTwoOutContext<'a, S, T, U> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 532 | where [INFO] [stdout] 533 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:471:25 [INFO] [stdout] | [INFO] [stdout] 468 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 471 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:546:8 [INFO] [stdout] | [INFO] [stdout] 546 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 550 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:468:56 [INFO] [stdout] | [INFO] [stdout] 468 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 469 | | time, [INFO] [stdout] 470 | | config, [INFO] [stdout] 471 | | &mut mutable_state, [INFO] [stdout] 472 | | left_write_stream, [INFO] [stdout] 473 | | right_write_stream, [INFO] [stdout] 474 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:533:8 [INFO] [stdout] | [INFO] [stdout] 531 | pub struct OneInTwoOutContext<'a, S, T, U> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 532 | where [INFO] [stdout] 533 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:468:51 [INFO] [stdout] | [INFO] [stdout] 352 | impl OneInMessageProcessorT for OneInTwoOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 468 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 469 | | time, [INFO] [stdout] 470 | | config, [INFO] [stdout] 471 | | &mut mutable_state, [INFO] [stdout] 472 | | left_write_stream, [INFO] [stdout] 473 | | right_write_stream, [INFO] [stdout] 474 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInTwoOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::OneInTwoOutContext<'_, std::sync::MutexGuard<'_, S>, U, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:318:8 [INFO] [stdout] | [INFO] [stdout] 318 | fn on_watermark(&mut self, ctx: &mut OneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:468:51 [INFO] [stdout] | [INFO] [stdout] 352 | impl OneInMessageProcessorT for OneInTwoOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 468 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 469 | | time, [INFO] [stdout] 470 | | config, [INFO] [stdout] 471 | | &mut mutable_state, [INFO] [stdout] 472 | | left_write_stream, [INFO] [stdout] 473 | | right_write_stream, [INFO] [stdout] 474 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInTwoOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::OneInTwoOutContext<'_, std::sync::MutexGuard<'_, S>, U, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:318:8 [INFO] [stdout] | [INFO] [stdout] 318 | fn on_watermark(&mut self, ctx: &mut OneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:504:25 [INFO] [stdout] | [INFO] [stdout] 501 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 504 | &mut state.lock().unwrap(), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:546:8 [INFO] [stdout] | [INFO] [stdout] 546 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 550 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:501:56 [INFO] [stdout] | [INFO] [stdout] 501 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 502 | | time.clone(), [INFO] [stdout] 503 | | config, [INFO] [stdout] 504 | | &mut state.lock().unwrap(), [INFO] [stdout] 505 | | left_write_stream, [INFO] [stdout] 506 | | right_write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:533:8 [INFO] [stdout] | [INFO] [stdout] 531 | pub struct OneInTwoOutContext<'a, S, T, U> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 532 | where [INFO] [stdout] 533 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:504:25 [INFO] [stdout] | [INFO] [stdout] 501 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 504 | &mut state.lock().unwrap(), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:546:8 [INFO] [stdout] | [INFO] [stdout] 546 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 550 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:501:56 [INFO] [stdout] | [INFO] [stdout] 501 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 502 | | time.clone(), [INFO] [stdout] 503 | | config, [INFO] [stdout] 504 | | &mut state.lock().unwrap(), [INFO] [stdout] 505 | | left_write_stream, [INFO] [stdout] 506 | | right_write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::OneInTwoOutContext` [INFO] [stdout] --> src/dataflow/context.rs:533:8 [INFO] [stdout] | [INFO] [stdout] 531 | pub struct OneInTwoOutContext<'a, S, T, U> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 532 | where [INFO] [stdout] 533 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::OneInTwoOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:501:51 [INFO] [stdout] | [INFO] [stdout] 352 | impl OneInMessageProcessorT for OneInTwoOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 501 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 502 | | time.clone(), [INFO] [stdout] 503 | | config, [INFO] [stdout] 504 | | &mut state.lock().unwrap(), [INFO] [stdout] 505 | | left_write_stream, [INFO] [stdout] 506 | | right_write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInTwoOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::OneInTwoOutContext<'_, std::sync::MutexGuard<'_, S>, U, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:318:8 [INFO] [stdout] | [INFO] [stdout] 318 | fn on_watermark(&mut self, ctx: &mut OneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/one_in_two_out_executor.rs:501:51 [INFO] [stdout] | [INFO] [stdout] 352 | impl OneInMessageProcessorT for OneInTwoOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 501 | mutable_operator.on_watermark(&mut OneInTwoOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 502 | | time.clone(), [INFO] [stdout] 503 | | config, [INFO] [stdout] 504 | | &mut state.lock().unwrap(), [INFO] [stdout] 505 | | left_write_stream, [INFO] [stdout] 506 | | right_write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::OneInTwoOutContext<'_, S, U, V>` [INFO] [stdout] found mutable reference `&mut context::OneInTwoOutContext<'_, std::sync::MutexGuard<'_, S>, U, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:318:8 [INFO] [stdout] | [INFO] [stdout] 318 | fn on_watermark(&mut self, ctx: &mut OneInTwoOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:107:61 [INFO] [stdout] | [INFO] [stdout] 107 | &ParallelSinkContext::new(time, config, &state), [INFO] [stdout] | ------------------------ ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:84:18 [INFO] [stdout] | [INFO] [stdout] 84 | S: 'static + AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] 85 | { [INFO] [stdout] 86 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:107:61 [INFO] [stdout] | [INFO] [stdout] 107 | &ParallelSinkContext::new(time, config, &state), [INFO] [stdout] | ------------------------ ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:84:18 [INFO] [stdout] | [INFO] [stdout] 84 | S: 'static + AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] 85 | { [INFO] [stdout] 86 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:107:22 [INFO] [stdout] | [INFO] [stdout] 107 | &ParallelSinkContext::new(time, config, &state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext` [INFO] [stdout] --> src/dataflow/context.rs:75:39 [INFO] [stdout] | [INFO] [stdout] 75 | pub struct ParallelSinkContext<'a, S: AppendableState, T> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:107:22 [INFO] [stdout] | [INFO] [stdout] 107 | &ParallelSinkContext::new(time, config, &state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext` [INFO] [stdout] --> src/dataflow/context.rs:75:39 [INFO] [stdout] | [INFO] [stdout] 75 | pub struct ParallelSinkContext<'a, S: AppendableState, T> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:107:21 [INFO] [stdout] | [INFO] [stdout] 67 | impl OneInMessageProcessorT for ParallelSinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 106 | operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 107 | &ParallelSinkContext::new(time, config, &state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelSinkContext<'_, S, U>` [INFO] [stdout] found reference `&context::ParallelSinkContext<'_, Arc, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:51:8 [INFO] [stdout] | [INFO] [stdout] 51 | fn on_data(&self, ctx: &ParallelSinkContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:107:21 [INFO] [stdout] | [INFO] [stdout] 67 | impl OneInMessageProcessorT for ParallelSinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 106 | operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 107 | &ParallelSinkContext::new(time, config, &state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelSinkContext<'_, S, U>` [INFO] [stdout] found reference `&context::ParallelSinkContext<'_, Arc, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:51:8 [INFO] [stdout] | [INFO] [stdout] 51 | fn on_data(&self, ctx: &ParallelSinkContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:130:91 [INFO] [stdout] | [INFO] [stdout] 130 | operator.on_watermark(&mut ParallelSinkContext::new(time.clone(), config, &state)); [INFO] [stdout] | ------------------------ ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:84:18 [INFO] [stdout] | [INFO] [stdout] 84 | S: 'static + AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] 85 | { [INFO] [stdout] 86 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:130:91 [INFO] [stdout] | [INFO] [stdout] 130 | operator.on_watermark(&mut ParallelSinkContext::new(time.clone(), config, &state)); [INFO] [stdout] | ------------------------ ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:84:18 [INFO] [stdout] | [INFO] [stdout] 84 | S: 'static + AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext::<'a, S, T>::new` [INFO] [stdout] 85 | { [INFO] [stdout] 86 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:130:44 [INFO] [stdout] | [INFO] [stdout] 130 | operator.on_watermark(&mut ParallelSinkContext::new(time.clone(), config, &state)); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext` [INFO] [stdout] --> src/dataflow/context.rs:75:39 [INFO] [stdout] | [INFO] [stdout] 75 | pub struct ParallelSinkContext<'a, S: AppendableState, T> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:130:44 [INFO] [stdout] | [INFO] [stdout] 130 | operator.on_watermark(&mut ParallelSinkContext::new(time.clone(), config, &state)); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelSinkContext` [INFO] [stdout] --> src/dataflow/context.rs:75:39 [INFO] [stdout] | [INFO] [stdout] 75 | pub struct ParallelSinkContext<'a, S: AppendableState, T> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelSinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:130:39 [INFO] [stdout] | [INFO] [stdout] 67 | impl OneInMessageProcessorT for ParallelSinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 130 | operator.on_watermark(&mut ParallelSinkContext::new(time.clone(), config, &state)); [INFO] [stdout] | ------------ ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | | [INFO] [stdout] | arguments to this function are incorrect [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelSinkContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::ParallelSinkContext<'_, Arc, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:53:8 [INFO] [stdout] | [INFO] [stdout] 53 | fn on_watermark(&self, ctx: &mut ParallelSinkContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:130:39 [INFO] [stdout] | [INFO] [stdout] 67 | impl OneInMessageProcessorT for ParallelSinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 130 | operator.on_watermark(&mut ParallelSinkContext::new(time.clone(), config, &state)); [INFO] [stdout] | ------------ ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | | [INFO] [stdout] | arguments to this function are incorrect [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelSinkContext<'_, S, U>` [INFO] [stdout] found mutable reference `&mut context::ParallelSinkContext<'_, Arc, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:53:8 [INFO] [stdout] | [INFO] [stdout] 53 | fn on_watermark(&self, ctx: &mut ParallelSinkContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:261:57 [INFO] [stdout] | [INFO] [stdout] 261 | &mut SinkContext::new(time, config, &mut mutable_state), [INFO] [stdout] | ---------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] --> src/dataflow/context.rs:127:8 [INFO] [stdout] | [INFO] [stdout] 127 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] 128 | { [INFO] [stdout] 129 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a mut S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:261:57 [INFO] [stdout] | [INFO] [stdout] 261 | &mut SinkContext::new(time, config, &mut mutable_state), [INFO] [stdout] | ---------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] --> src/dataflow/context.rs:127:8 [INFO] [stdout] | [INFO] [stdout] 127 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] 128 | { [INFO] [stdout] 129 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a mut S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:261:26 [INFO] [stdout] | [INFO] [stdout] 261 | &mut SinkContext::new(time, config, &mut mutable_state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext` [INFO] [stdout] --> src/dataflow/context.rs:119:31 [INFO] [stdout] | [INFO] [stdout] 119 | pub struct SinkContext<'a, S: State> { [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:261:26 [INFO] [stdout] | [INFO] [stdout] 261 | &mut SinkContext::new(time, config, &mut mutable_state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext` [INFO] [stdout] --> src/dataflow/context.rs:119:31 [INFO] [stdout] | [INFO] [stdout] 119 | pub struct SinkContext<'a, S: State> { [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:261:21 [INFO] [stdout] | [INFO] [stdout] 223 | impl OneInMessageProcessorT for SinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 260 | mutable_operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 261 | &mut SinkContext::new(time, config, &mut mutable_state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::SinkContext<'_, S>` [INFO] [stdout] found mutable reference `&mut context::SinkContext<'_, std::sync::MutexGuard<'_, S>>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:76:8 [INFO] [stdout] | [INFO] [stdout] 76 | fn on_data(&mut self, ctx: &mut SinkContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:261:21 [INFO] [stdout] | [INFO] [stdout] 223 | impl OneInMessageProcessorT for SinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 260 | mutable_operator.on_data( [INFO] [stdout] | ------- arguments to this function are incorrect [INFO] [stdout] 261 | &mut SinkContext::new(time, config, &mut mutable_state), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::SinkContext<'_, S>` [INFO] [stdout] found mutable reference `&mut context::SinkContext<'_, std::sync::MutexGuard<'_, S>>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:76:8 [INFO] [stdout] | [INFO] [stdout] 76 | fn on_data(&mut self, ctx: &mut SinkContext, data: &T); [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:289:21 [INFO] [stdout] | [INFO] [stdout] 286 | mutable_operator.on_watermark(&mut SinkContext::new( [INFO] [stdout] | ---------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 289 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] --> src/dataflow/context.rs:127:8 [INFO] [stdout] | [INFO] [stdout] 127 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] 128 | { [INFO] [stdout] 129 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a mut S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:289:21 [INFO] [stdout] | [INFO] [stdout] 286 | mutable_operator.on_watermark(&mut SinkContext::new( [INFO] [stdout] | ---------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 289 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] --> src/dataflow/context.rs:127:8 [INFO] [stdout] | [INFO] [stdout] 127 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext::<'a, S>::new` [INFO] [stdout] 128 | { [INFO] [stdout] 129 | pub fn new(timestamp: Timestamp, config: OperatorConfig, state: &'a mut S) -> Self { [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:286:52 [INFO] [stdout] | [INFO] [stdout] 286 | mutable_operator.on_watermark(&mut SinkContext::new( [INFO] [stdout] | ____________________________________________________^ [INFO] [stdout] 287 | | time.clone(), [INFO] [stdout] 288 | | config, [INFO] [stdout] 289 | | &mut mutable_state, [INFO] [stdout] 290 | | )); [INFO] [stdout] | |_________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext` [INFO] [stdout] --> src/dataflow/context.rs:119:31 [INFO] [stdout] | [INFO] [stdout] 119 | pub struct SinkContext<'a, S: State> { [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:286:52 [INFO] [stdout] | [INFO] [stdout] 286 | mutable_operator.on_watermark(&mut SinkContext::new( [INFO] [stdout] | ____________________________________________________^ [INFO] [stdout] 287 | | time.clone(), [INFO] [stdout] 288 | | config, [INFO] [stdout] 289 | | &mut mutable_state, [INFO] [stdout] 290 | | )); [INFO] [stdout] | |_________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::SinkContext` [INFO] [stdout] --> src/dataflow/context.rs:119:31 [INFO] [stdout] | [INFO] [stdout] 119 | pub struct SinkContext<'a, S: State> { [INFO] [stdout] | ^^^^^ required by this bound in `context::SinkContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:286:47 [INFO] [stdout] | [INFO] [stdout] 223 | impl OneInMessageProcessorT for SinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 286 | mutable_operator.on_watermark(&mut SinkContext::new( [INFO] [stdout] | __________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 287 | | time.clone(), [INFO] [stdout] 288 | | config, [INFO] [stdout] 289 | | &mut mutable_state, [INFO] [stdout] 290 | | )); [INFO] [stdout] | |_________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::SinkContext<'_, S>` [INFO] [stdout] found mutable reference `&mut context::SinkContext<'_, std::sync::MutexGuard<'_, S>>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:78:8 [INFO] [stdout] | [INFO] [stdout] 78 | fn on_watermark(&mut self, ctx: &mut SinkContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/sink_executor.rs:286:47 [INFO] [stdout] | [INFO] [stdout] 223 | impl OneInMessageProcessorT for SinkMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 286 | mutable_operator.on_watermark(&mut SinkContext::new( [INFO] [stdout] | __________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 287 | | time.clone(), [INFO] [stdout] 288 | | config, [INFO] [stdout] 289 | | &mut mutable_state, [INFO] [stdout] 290 | | )); [INFO] [stdout] | |_________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::SinkContext<'_, S>` [INFO] [stdout] found mutable reference `&mut context::SinkContext<'_, std::sync::MutexGuard<'_, S>>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:78:8 [INFO] [stdout] | [INFO] [stdout] 78 | fn on_watermark(&mut self, ctx: &mut SinkContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:149:68 [INFO] [stdout] | [INFO] [stdout] 149 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ------------------------------- ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:149:22 [INFO] [stdout] | [INFO] [stdout] 149 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:149:68 [INFO] [stdout] | [INFO] [stdout] 149 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ------------------------------- ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:149:22 [INFO] [stdout] | [INFO] [stdout] 149 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:149:21 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 148 | operator.on_left_data( [INFO] [stdout] | ------------ arguments to this function are incorrect [INFO] [stdout] 149 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found reference `&context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:194:8 [INFO] [stdout] | [INFO] [stdout] 194 | fn on_left_data(&self, ctx: &ParallelTwoInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:173:68 [INFO] [stdout] | [INFO] [stdout] 173 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ------------------------------- ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:173:22 [INFO] [stdout] | [INFO] [stdout] 173 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:149:21 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 148 | operator.on_left_data( [INFO] [stdout] | ------------ arguments to this function are incorrect [INFO] [stdout] 149 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found reference `&context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:194:8 [INFO] [stdout] | [INFO] [stdout] 194 | fn on_left_data(&self, ctx: &ParallelTwoInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:173:68 [INFO] [stdout] | [INFO] [stdout] 173 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ------------------------------- ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:173:22 [INFO] [stdout] | [INFO] [stdout] 173 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:173:21 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 172 | operator.on_right_data( [INFO] [stdout] | ------------- arguments to this function are incorrect [INFO] [stdout] 173 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found reference `&context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:196:8 [INFO] [stdout] | [INFO] [stdout] 196 | fn on_right_data(&self, ctx: &ParallelTwoInOneOutContext, data: &U); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:203:25 [INFO] [stdout] | [INFO] [stdout] 200 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 203 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:200:48 [INFO] [stdout] | [INFO] [stdout] 200 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 201 | | time, [INFO] [stdout] 202 | | config, [INFO] [stdout] 203 | | &state, [INFO] [stdout] 204 | | write_stream, [INFO] [stdout] 205 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:173:21 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 172 | operator.on_right_data( [INFO] [stdout] | ------------- arguments to this function are incorrect [INFO] [stdout] 173 | &ParallelTwoInOneOutContext::new(time, config, &state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected reference `&context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found reference `&context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:196:8 [INFO] [stdout] | [INFO] [stdout] 196 | fn on_right_data(&self, ctx: &ParallelTwoInOneOutContext, data: &U); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:203:25 [INFO] [stdout] | [INFO] [stdout] 200 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 203 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:200:48 [INFO] [stdout] | [INFO] [stdout] 200 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 201 | | time, [INFO] [stdout] 202 | | config, [INFO] [stdout] 203 | | &state, [INFO] [stdout] 204 | | write_stream, [INFO] [stdout] 205 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:200:43 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 200 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 201 | | time, [INFO] [stdout] 202 | | config, [INFO] [stdout] 203 | | &state, [INFO] [stdout] 204 | | write_stream, [INFO] [stdout] 205 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:198:8 [INFO] [stdout] | [INFO] [stdout] 198 | fn on_watermark(&self, ctx: &mut ParallelTwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:229:25 [INFO] [stdout] | [INFO] [stdout] 226 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 229 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:226:48 [INFO] [stdout] | [INFO] [stdout] 226 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 227 | | time.clone(), [INFO] [stdout] 228 | | config, [INFO] [stdout] 229 | | &state, [INFO] [stdout] 230 | | write_stream, [INFO] [stdout] 231 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:200:43 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 200 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 201 | | time, [INFO] [stdout] 202 | | config, [INFO] [stdout] 203 | | &state, [INFO] [stdout] 204 | | write_stream, [INFO] [stdout] 205 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:198:8 [INFO] [stdout] | [INFO] [stdout] 198 | fn on_watermark(&self, ctx: &mut ParallelTwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:229:25 [INFO] [stdout] | [INFO] [stdout] 226 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ------------------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 229 | &state, [INFO] [stdout] | ^^^^^^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] --> src/dataflow/context.rs:329:8 [INFO] [stdout] | [INFO] [stdout] 329 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext::<'a, S, T, U>::new` [INFO] [stdout] ... [INFO] [stdout] 332 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `Arc: AppendableState<_>` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:226:48 [INFO] [stdout] | [INFO] [stdout] 226 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________^ [INFO] [stdout] 227 | | time.clone(), [INFO] [stdout] 228 | | config, [INFO] [stdout] 229 | | &state, [INFO] [stdout] 230 | | write_stream, [INFO] [stdout] 231 | | )); [INFO] [stdout] | |_____________________^ the trait `AppendableState<_>` is not implemented for `Arc` [INFO] [stdout] | [INFO] [stdout] note: required by a bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:317:8 [INFO] [stdout] | [INFO] [stdout] 315 | pub struct ParallelTwoInOneOutContext<'a, S, T, U> [INFO] [stdout] | -------------------------- required by a bound in this [INFO] [stdout] 316 | where [INFO] [stdout] 317 | S: AppendableState, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ required by this bound in `context::ParallelTwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:226:43 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 226 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 227 | | time.clone(), [INFO] [stdout] 228 | | config, [INFO] [stdout] 229 | | &state, [INFO] [stdout] 230 | | write_stream, [INFO] [stdout] 231 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:198:8 [INFO] [stdout] | [INFO] [stdout] 198 | fn on_watermark(&self, ctx: &mut ParallelTwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:415:64 [INFO] [stdout] | [INFO] [stdout] 415 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ----------------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:415:26 [INFO] [stdout] | [INFO] [stdout] 415 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:226:43 [INFO] [stdout] | [INFO] [stdout] 78 | impl TwoInMessageProcessorT [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 226 | operator.on_watermark(&mut ParallelTwoInOneOutContext::new( [INFO] [stdout] | ______________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 227 | | time.clone(), [INFO] [stdout] 228 | | config, [INFO] [stdout] 229 | | &state, [INFO] [stdout] 230 | | write_stream, [INFO] [stdout] 231 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `Arc` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::ParallelTwoInOneOutContext<'_, S, V, W>` [INFO] [stdout] found mutable reference `&mut context::ParallelTwoInOneOutContext<'_, Arc, V, _>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:198:8 [INFO] [stdout] | [INFO] [stdout] 198 | fn on_watermark(&self, ctx: &mut ParallelTwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:415:64 [INFO] [stdout] | [INFO] [stdout] 415 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ----------------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:415:26 [INFO] [stdout] | [INFO] [stdout] 415 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:415:21 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 414 | mutable_operator.on_left_data( [INFO] [stdout] | ------------ arguments to this function are incorrect [INFO] [stdout] 415 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:234:8 [INFO] [stdout] | [INFO] [stdout] 234 | fn on_left_data(&mut self, ctx: &mut TwoInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:443:64 [INFO] [stdout] | [INFO] [stdout] 443 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ----------------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:443:26 [INFO] [stdout] | [INFO] [stdout] 443 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:415:21 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 414 | mutable_operator.on_left_data( [INFO] [stdout] | ------------ arguments to this function are incorrect [INFO] [stdout] 415 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:234:8 [INFO] [stdout] | [INFO] [stdout] 234 | fn on_left_data(&mut self, ctx: &mut TwoInOneOutContext, data: &T); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:443:64 [INFO] [stdout] | [INFO] [stdout] 443 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ----------------------- ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | | [INFO] [stdout] | required by a bound introduced by this call [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:443:26 [INFO] [stdout] | [INFO] [stdout] 443 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:443:21 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 442 | mutable_operator.on_right_data( [INFO] [stdout] | ------------- arguments to this function are incorrect [INFO] [stdout] 443 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:236:8 [INFO] [stdout] | [INFO] [stdout] 236 | fn on_right_data(&mut self, ctx: &mut TwoInOneOutContext, data: &U); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:476:25 [INFO] [stdout] | [INFO] [stdout] 473 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 476 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:473:56 [INFO] [stdout] | [INFO] [stdout] 473 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 474 | | time, [INFO] [stdout] 475 | | config, [INFO] [stdout] 476 | | &mut mutable_state, [INFO] [stdout] 477 | | write_stream, [INFO] [stdout] 478 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:443:21 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 442 | mutable_operator.on_right_data( [INFO] [stdout] | ------------- arguments to this function are incorrect [INFO] [stdout] 443 | &mut TwoInOneOutContext::new(time, config, &mut mutable_state, write_stream), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:236:8 [INFO] [stdout] | [INFO] [stdout] 236 | fn on_right_data(&mut self, ctx: &mut TwoInOneOutContext, data: &U); [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:476:25 [INFO] [stdout] | [INFO] [stdout] 473 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 476 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:473:56 [INFO] [stdout] | [INFO] [stdout] 473 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 474 | | time, [INFO] [stdout] 475 | | config, [INFO] [stdout] 476 | | &mut mutable_state, [INFO] [stdout] 477 | | write_stream, [INFO] [stdout] 478 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:473:51 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 473 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 474 | | time, [INFO] [stdout] 475 | | config, [INFO] [stdout] 476 | | &mut mutable_state, [INFO] [stdout] 477 | | write_stream, [INFO] [stdout] 478 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:238:8 [INFO] [stdout] | [INFO] [stdout] 238 | fn on_watermark(&mut self, ctx: &mut TwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:505:25 [INFO] [stdout] | [INFO] [stdout] 502 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 505 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:502:56 [INFO] [stdout] | [INFO] [stdout] 502 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 503 | | time.clone(), [INFO] [stdout] 504 | | config, [INFO] [stdout] 505 | | &mut mutable_state, [INFO] [stdout] 506 | | write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:473:51 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 473 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 474 | | time, [INFO] [stdout] 475 | | config, [INFO] [stdout] 476 | | &mut mutable_state, [INFO] [stdout] 477 | | write_stream, [INFO] [stdout] 478 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:238:8 [INFO] [stdout] | [INFO] [stdout] 238 | fn on_watermark(&mut self, ctx: &mut TwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:505:25 [INFO] [stdout] | [INFO] [stdout] 502 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ----------------------- required by a bound introduced by this call [INFO] [stdout] ... [INFO] [stdout] 505 | &mut mutable_state, [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] --> src/dataflow/context.rs:389:8 [INFO] [stdout] | [INFO] [stdout] 389 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext::<'a, S, T>::new` [INFO] [stdout] ... [INFO] [stdout] 392 | pub fn new( [INFO] [stdout] | --- required by a bound in this [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0277]: the trait bound `std::sync::MutexGuard<'_, S>: State` is not satisfied [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:502:56 [INFO] [stdout] | [INFO] [stdout] 502 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ________________________________________________________^ [INFO] [stdout] 503 | | time.clone(), [INFO] [stdout] 504 | | config, [INFO] [stdout] 505 | | &mut mutable_state, [INFO] [stdout] 506 | | write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ the trait `State` is not implemented for `std::sync::MutexGuard<'_, S>` [INFO] [stdout] | [INFO] [stdout] = help: the following other types implement trait `State`: [INFO] [stdout] () [INFO] [stdout] TimeVersionedState [INFO] [stdout] note: required by a bound in `context::TwoInOneOutContext` [INFO] [stdout] --> src/dataflow/context.rs:378:8 [INFO] [stdout] | [INFO] [stdout] 376 | pub struct TwoInOneOutContext<'a, S, T> [INFO] [stdout] | ------------------ required by a bound in this [INFO] [stdout] 377 | where [INFO] [stdout] 378 | S: State, [INFO] [stdout] | ^^^^^ required by this bound in `context::TwoInOneOutContext` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:502:51 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 502 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 503 | | time.clone(), [INFO] [stdout] 504 | | config, [INFO] [stdout] 505 | | &mut mutable_state, [INFO] [stdout] 506 | | write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:238:8 [INFO] [stdout] | [INFO] [stdout] 238 | fn on_watermark(&mut self, ctx: &mut TwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0308]: mismatched types [INFO] [stdout] --> src/node/operator_executors/two_in_one_out_executor.rs:502:51 [INFO] [stdout] | [INFO] [stdout] 344 | impl TwoInMessageProcessorT for TwoInOneOutMessageProcessor [INFO] [stdout] | - this type parameter [INFO] [stdout] ... [INFO] [stdout] 502 | mutable_operator.on_watermark(&mut TwoInOneOutContext::new( [INFO] [stdout] | ______________________________________------------_^ [INFO] [stdout] | | | [INFO] [stdout] | | arguments to this function are incorrect [INFO] [stdout] 503 | | time.clone(), [INFO] [stdout] 504 | | config, [INFO] [stdout] 505 | | &mut mutable_state, [INFO] [stdout] 506 | | write_stream, [INFO] [stdout] 507 | | )); [INFO] [stdout] | |_____________________^ expected type parameter `S`, found struct `std::sync::MutexGuard` [INFO] [stdout] | [INFO] [stdout] = note: expected mutable reference `&mut context::TwoInOneOutContext<'_, S, V>` [INFO] [stdout] found mutable reference `&mut context::TwoInOneOutContext<'_, std::sync::MutexGuard<'_, S>, V>` [INFO] [stdout] note: associated function defined here [INFO] [stdout] --> src/dataflow/operator.rs:238:8 [INFO] [stdout] | [INFO] [stdout] 238 | fn on_watermark(&mut self, ctx: &mut TwoInOneOutContext); [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error: aborting due to 72 previous errors [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0277, E0308. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stderr] error: could not compile `erdos` due to 73 previous errors [INFO] [stderr] warning: build failed, waiting for other jobs to finish... [INFO] [stdout] error: aborting due to 72 previous errors [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0277, E0308. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0277`. [INFO] [stdout] [INFO] [stderr] error: could not compile `erdos` due to 73 previous errors [INFO] running `Command { std: "docker" "inspect" "52951ea4078724eec3d23268d1185b61f8dd6980628b19e26381a180ddaa0007", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "52951ea4078724eec3d23268d1185b61f8dd6980628b19e26381a180ddaa0007", kill_on_drop: false }` [INFO] [stdout] 52951ea4078724eec3d23268d1185b61f8dd6980628b19e26381a180ddaa0007