[INFO] crate erdos 0.2.0 is already in cache [INFO] testing erdos-0.2.0 against master#28742a1146f10a4f09369baad027a464acb7a766 for pr-71274 [INFO] extracting crate erdos 0.2.0 into /workspace/builds/worker-5/source [INFO] validating manifest of crates.io crate erdos 0.2.0 on toolchain 28742a1146f10a4f09369baad027a464acb7a766 [INFO] running `"/workspace/cargo-home/bin/cargo" "+28742a1146f10a4f09369baad027a464acb7a766" "read-manifest" "--manifest-path" "Cargo.toml"` [INFO] started tweaking crates.io crate erdos 0.2.0 [INFO] finished tweaking crates.io crate erdos 0.2.0 [INFO] tweaked toml for crates.io crate erdos 0.2.0 written to /workspace/builds/worker-5/source/Cargo.toml [INFO] crate crates.io crate erdos 0.2.0 already has a lockfile, it will not be regenerated [INFO] running `"/workspace/cargo-home/bin/cargo" "+28742a1146f10a4f09369baad027a464acb7a766" "fetch" "--locked" "--manifest-path" "Cargo.toml"` [INFO] running `"docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/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" "MAP_USER_ID=0" "-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" "--network" "none" "rustops/crates-build-env" "/opt/rustwide/cargo-home/bin/cargo" "+28742a1146f10a4f09369baad027a464acb7a766" "build" "--frozen"` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] d8b8361635806f35cf9ef77848a39564ea1fdd576fbe790064f653a63d51437b [INFO] running `"docker" "start" "-a" "d8b8361635806f35cf9ef77848a39564ea1fdd576fbe790064f653a63d51437b"` [INFO] [stderr] Compiling proc-macro2 v1.0.7 [INFO] [stderr] Compiling libc v0.2.66 [INFO] [stderr] Compiling autocfg v0.1.7 [INFO] [stderr] Compiling memchr v2.3.0 [INFO] [stderr] Compiling futures-core-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling futures-sink-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling byteorder v1.3.2 [INFO] [stderr] Compiling rand_core v0.4.2 [INFO] [stderr] Compiling serde v1.0.104 [INFO] [stderr] Compiling scopeguard v1.0.0 [INFO] [stderr] Compiling futures-io-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling ryu v1.0.2 [INFO] [stderr] Compiling itoa v0.4.4 [INFO] [stderr] Compiling regex-syntax v0.6.13 [INFO] [stderr] Compiling unindent v0.1.5 [INFO] [stderr] Compiling bitflags v1.2.1 [INFO] [stderr] Compiling unicode-width v0.1.7 [INFO] [stderr] Compiling spin v0.5.2 [INFO] [stderr] Compiling sha1 v0.6.0 [INFO] [stderr] Compiling strsim v0.8.0 [INFO] [stderr] Compiling vec_map v0.8.1 [INFO] [stderr] Compiling abomonation v0.7.3 [INFO] [stderr] Compiling tracing-core v0.1.9 [INFO] [stderr] Compiling thread_local v0.3.6 [INFO] [stderr] Compiling futures-channel-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling rand_core v0.3.1 [INFO] [stderr] Compiling rand_jitter v0.1.4 [INFO] [stderr] Compiling lock_api v0.3.3 [INFO] [stderr] Compiling textwrap v0.11.0 [INFO] [stderr] Compiling crossbeam-utils v0.7.0 [INFO] [stderr] Compiling crossbeam-epoch v0.8.0 [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] Compiling crossbeam-queue v0.1.2 [INFO] [stderr] Compiling rand_xorshift v0.1.1 [INFO] [stderr] Compiling rand_hc v0.1.0 [INFO] [stderr] Compiling rand_isaac v0.1.1 [INFO] [stderr] Compiling memoffset v0.5.3 [INFO] [stderr] Compiling futures-util-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling aho-corasick v0.7.6 [INFO] [stderr] Compiling quote v1.0.2 [INFO] [stderr] Compiling iovec v0.1.4 [INFO] [stderr] Compiling num_cpus v1.12.0 [INFO] [stderr] Compiling net2 v0.2.33 [INFO] [stderr] Compiling dirs-sys v0.3.4 [INFO] [stderr] Compiling parking_lot_core v0.6.2 [INFO] [stderr] Compiling time v0.1.42 [INFO] [stderr] Compiling rand_os v0.1.3 [INFO] [stderr] Compiling atty v0.2.14 [INFO] [stderr] Compiling rand v0.4.6 [INFO] [stderr] Compiling bytes v0.4.12 [INFO] [stderr] Compiling syn v1.0.13 [INFO] [stderr] Compiling mio v0.6.21 [INFO] [stderr] Compiling dirs v2.0.2 [INFO] [stderr] Compiling parking_lot v0.9.0 [INFO] [stderr] Compiling clap v2.33.0 [INFO] [stderr] Compiling regex v1.3.3 [INFO] [stderr] Compiling chrono v0.4.10 [INFO] [stderr] Compiling term v0.6.1 [INFO] [stderr] Compiling tokio-serde v0.3.0 [INFO] [stderr] Compiling rand v0.3.23 [INFO] [stderr] Compiling mio-uds v0.6.7 [INFO] [stderr] Compiling tokio-sync v0.2.0-alpha.6 [INFO] [stderr] Compiling futures-executor-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling crossbeam-deque v0.7.2 [INFO] [stderr] Compiling slog-term v2.4.2 [INFO] [stderr] Compiling futures-preview v0.3.0-alpha.19 [INFO] [stderr] Compiling pyo3-derive-backend v0.8.5 [INFO] [stderr] Compiling synstructure v0.12.3 [INFO] [stderr] Compiling serde_derive v1.0.104 [INFO] [stderr] Compiling tracing-attributes v0.1.6 [INFO] [stderr] Compiling pin-project-internal v0.4.6 [INFO] [stderr] Compiling proc-macro-hack v0.5.11 [INFO] [stderr] Compiling ctor v0.1.12 [INFO] [stderr] Compiling inventory-impl v0.1.5 [INFO] [stderr] Compiling ghost v0.1.1 [INFO] [stderr] Compiling tokio-macros v0.2.0-alpha.6 [INFO] [stderr] Compiling async-trait v0.1.22 [INFO] [stderr] Compiling abomonation_derive v0.5.0 [INFO] [stderr] Compiling pyo3cls v0.8.5 [INFO] [stderr] Compiling indoc-impl v0.3.4 [INFO] [stderr] Compiling paste-impl v0.1.6 [INFO] [stderr] Compiling tracing v0.1.12 [INFO] [stderr] Compiling pin-project v0.4.6 [INFO] [stderr] Compiling tokio-executor v0.2.0-alpha.6 [INFO] [stderr] Compiling inventory v0.1.5 [INFO] [stderr] Compiling tokio-io v0.2.0-alpha.6 [INFO] [stderr] Compiling indoc v0.3.4 [INFO] [stderr] Compiling paste v0.1.6 [INFO] [stderr] Compiling tokio-codec v0.2.0-alpha.6 [INFO] [stderr] Compiling tokio-timer v0.3.0-alpha.6 [INFO] [stderr] Compiling tokio-net v0.2.0-alpha.6 [INFO] [stderr] Compiling tokio-fs v0.2.0-alpha.6 [INFO] [stderr] Compiling tokio v0.2.0-alpha.6 [INFO] [stderr] Compiling serde_json v1.0.44 [INFO] [stderr] Compiling bincode v1.2.1 [INFO] [stderr] Compiling uuid v0.7.4 [INFO] [stderr] Compiling tokio-serde-bincode v0.2.1 [INFO] [stderr] Compiling pyo3 v0.8.5 [INFO] [stderr] Compiling erdos v0.2.0 (/opt/rustwide/workdir) [INFO] [stderr] warning: unused variable: `left_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:81:9 [INFO] [stderr] | [INFO] [stderr] 81 | left_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_left_state` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused variable: `right_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:82:9 [INFO] [stderr] | [INFO] [stderr] 82 | right_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_right_state` [INFO] [stderr] [INFO] [stderr] warning: unused variable: `write_stream` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream: &mut WriteStream, [INFO] [stderr] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_write_stream` [INFO] [stderr] [INFO] [stderr] warning: field is never read: `logger` [INFO] [stderr] --> src/node/operator_executor.rs:50:5 [INFO] [stderr] | [INFO] [stderr] 50 | logger: slog::Logger, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(dead_code)]` on by default [INFO] [stderr] [INFO] [stderr] warning: 4 warnings emitted [INFO] [stderr] [INFO] [stderr] Finished dev [unoptimized + debuginfo] target(s) in 3m 38s [INFO] running `"docker" "inspect" "d8b8361635806f35cf9ef77848a39564ea1fdd576fbe790064f653a63d51437b"` [INFO] running `"docker" "rm" "-f" "d8b8361635806f35cf9ef77848a39564ea1fdd576fbe790064f653a63d51437b"` [INFO] [stdout] d8b8361635806f35cf9ef77848a39564ea1fdd576fbe790064f653a63d51437b [INFO] running `"docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/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" "MAP_USER_ID=0" "-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" "--network" "none" "rustops/crates-build-env" "/opt/rustwide/cargo-home/bin/cargo" "+28742a1146f10a4f09369baad027a464acb7a766" "test" "--frozen" "--no-run"` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] 316c2b67cd4ecd4b31976d333fe32b72ca77c7f37c717243eebcb549340fa699 [INFO] running `"docker" "start" "-a" "316c2b67cd4ecd4b31976d333fe32b72ca77c7f37c717243eebcb549340fa699"` [INFO] [stderr] Compiling failure_derive v0.1.6 [INFO] [stderr] Compiling cast v0.1.0 [INFO] [stderr] Compiling rustc-demangle v0.1.16 [INFO] [stderr] Compiling itertools v0.4.19 [INFO] [stderr] Compiling backtrace-sys v0.1.32 [INFO] [stderr] Compiling itertools v0.5.10 [INFO] [stderr] Compiling num_cpus v0.2.13 [INFO] [stderr] Compiling isatty v0.1.9 [INFO] [stderr] Compiling log v0.3.9 [INFO] [stderr] Compiling num-traits v0.1.43 [INFO] [stderr] warning: unused variable: `left_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:81:9 [INFO] [stderr] | [INFO] [stderr] 81 | left_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_left_state` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused variable: `right_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:82:9 [INFO] [stderr] | [INFO] [stderr] 82 | right_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_right_state` [INFO] [stderr] [INFO] [stderr] warning: unused variable: `write_stream` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream: &mut WriteStream, [INFO] [stderr] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_write_stream` [INFO] [stderr] [INFO] [stderr] warning: field is never read: `logger` [INFO] [stderr] --> src/node/operator_executor.rs:50:5 [INFO] [stderr] | [INFO] [stderr] 50 | logger: slog::Logger, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(dead_code)]` on by default [INFO] [stderr] [INFO] [stderr] warning: 4 warnings emitted [INFO] [stderr] [INFO] [stderr] Compiling criterion-stats v0.1.3 [INFO] [stderr] Compiling simplelog v0.4.4 [INFO] [stderr] Compiling backtrace v0.3.42 [INFO] [stderr] Compiling criterion-plot v0.1.3 [INFO] [stderr] Compiling failure v0.1.6 [INFO] [stderr] Compiling criterion v0.1.2 [INFO] [stderr] Compiling erdos v0.2.0 (/opt/rustwide/workdir) [INFO] [stderr] warning: unused imports: `JoinOperator`, `OperatorConfig`, `SourceOperator`, `graph::*` [INFO] [stderr] --> tests/driver_test.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | graph::*, [INFO] [stderr] | ^^^^^^^^ [INFO] [stderr] 3 | operators::{JoinOperator, SourceOperator}, [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^^^ [INFO] [stderr] 4 | OperatorConfig, [INFO] [stderr] | ^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `erdos::*` [INFO] [stderr] --> tests/driver_test.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use erdos::*; [INFO] [stderr] | ^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: unused import: `graph::default_graph` [INFO] [stderr] --> tests/inter_thread_test.rs:8:9 [INFO] [stderr] | [INFO] [stderr] 8 | graph::default_graph, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `operators::MapOperator` [INFO] [stderr] --> tests/loop_test.rs:5:21 [INFO] [stderr] | [INFO] [stderr] 5 | message::*, operators::MapOperator, stream::WriteStreamT, LoopStream, OperatorConfig, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused variable: `result` [INFO] [stderr] --> tests/inter_thread_test.rs:146:13 [INFO] [stderr] | [INFO] [stderr] 146 | let result = extract_stream.read(); [INFO] [stderr] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_result` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> tests/inter_thread_test.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream.send(Message::new_message(t, data * data)); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_must_use)]` on by default [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: 2 warnings emitted [INFO] [stderr] [INFO] [stderr] warning: 1 warning emitted [INFO] [stderr] [INFO] [stderr] warning: 3 warnings emitted [INFO] [stderr] [INFO] [stderr] warning: unused variable: `left_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:81:9 [INFO] [stderr] | [INFO] [stderr] 81 | left_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_left_state` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused variable: `right_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:82:9 [INFO] [stderr] | [INFO] [stderr] 82 | right_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_right_state` [INFO] [stderr] [INFO] [stderr] warning: unused variable: `write_stream` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream: &mut WriteStream, [INFO] [stderr] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_write_stream` [INFO] [stderr] [INFO] [stderr] warning: field is never read: `logger` [INFO] [stderr] --> src/node/operator_executor.rs:50:5 [INFO] [stderr] | [INFO] [stderr] 50 | logger: slog::Logger, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(dead_code)]` on by default [INFO] [stderr] [INFO] [stderr] warning: 4 warnings emitted [INFO] [stderr] [INFO] [stderr] Finished test [unoptimized + debuginfo] target(s) in 1m 03s [INFO] running `"docker" "inspect" "316c2b67cd4ecd4b31976d333fe32b72ca77c7f37c717243eebcb549340fa699"` [INFO] running `"docker" "rm" "-f" "316c2b67cd4ecd4b31976d333fe32b72ca77c7f37c717243eebcb549340fa699"` [INFO] [stdout] 316c2b67cd4ecd4b31976d333fe32b72ca77c7f37c717243eebcb549340fa699 [INFO] running `"docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/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" "MAP_USER_ID=0" "-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" "--network" "none" "rustops/crates-build-env" "/opt/rustwide/cargo-home/bin/cargo" "+28742a1146f10a4f09369baad027a464acb7a766" "test" "--frozen"` [INFO] [stderr] WARNING: Your kernel does not support swap limit capabilities or the cgroup is not mounted. Memory limited without swap. [INFO] [stdout] 8158d6db36210d82423cf9ecb9b5417e83d913e07b8196e5a5877a2bddd665d5 [INFO] running `"docker" "start" "-a" "8158d6db36210d82423cf9ecb9b5417e83d913e07b8196e5a5877a2bddd665d5"` [INFO] [stderr] warning: unused variable: `left_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:81:9 [INFO] [stderr] | [INFO] [stderr] 81 | left_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_left_state` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused variable: `left_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:81:9 [INFO] [stderr] | [INFO] [stderr] 81 | left_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_left_state` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused variable: `right_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:82:9 [INFO] [stderr] | [INFO] [stderr] 82 | right_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_right_state` [INFO] [stderr] [INFO] [stderr] warning: unused variable: `write_stream` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream: &mut WriteStream, [INFO] [stderr] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_write_stream` [INFO] [stderr] [INFO] [stderr] warning: unused variable: `right_state` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:82:9 [INFO] [stderr] | [INFO] [stderr] 82 | right_state: &WindowState, [INFO] [stderr] | ^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_right_state` [INFO] [stderr] [INFO] [stderr] warning: unused variable: `write_stream` [INFO] [stderr] --> src/dataflow/operators/join_operator.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream: &mut WriteStream, [INFO] [stderr] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_write_stream` [INFO] [stderr] [INFO] [stderr] warning: field is never read: `logger` [INFO] [stderr] --> src/node/operator_executor.rs:50:5 [INFO] [stderr] | [INFO] [stderr] 50 | logger: slog::Logger, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(dead_code)]` on by default [INFO] [stderr] [INFO] [stderr] warning: field is never read: `logger` [INFO] [stderr] --> src/node/operator_executor.rs:50:5 [INFO] [stderr] | [INFO] [stderr] 50 | logger: slog::Logger, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(dead_code)]` on by default [INFO] [stderr] [INFO] [stderr] warning: 4 warnings emitted [INFO] [stderr] [INFO] [stderr] warning: 4 warnings emitted [INFO] [stderr] [INFO] [stderr] warning: unused import: `graph::default_graph` [INFO] [stderr] --> tests/inter_thread_test.rs:8:9 [INFO] [stderr] | [INFO] [stderr] 8 | graph::default_graph, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused imports: `JoinOperator`, `OperatorConfig`, `SourceOperator`, `graph::*` [INFO] [stderr] --> tests/driver_test.rs:2:5 [INFO] [stderr] | [INFO] [stderr] 2 | graph::*, [INFO] [stderr] | ^^^^^^^^ [INFO] [stderr] 3 | operators::{JoinOperator, SourceOperator}, [INFO] [stderr] | ^^^^^^^^^^^^ ^^^^^^^^^^^^^^ [INFO] [stderr] 4 | OperatorConfig, [INFO] [stderr] | ^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `erdos::*` [INFO] [stderr] --> tests/driver_test.rs:6:5 [INFO] [stderr] | [INFO] [stderr] 6 | use erdos::*; [INFO] [stderr] | ^^^^^^^^ [INFO] [stderr] [INFO] [stderr] warning: 2 warnings emitted [INFO] [stderr] [INFO] [stderr] warning: unused variable: `result` [INFO] [stderr] --> tests/inter_thread_test.rs:146:13 [INFO] [stderr] | [INFO] [stderr] 146 | let result = extract_stream.read(); [INFO] [stderr] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_result` [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_variables)]` on by default [INFO] [stderr] [INFO] [stderr] warning: unused `std::result::Result` that must be used [INFO] [stderr] --> tests/inter_thread_test.rs:83:9 [INFO] [stderr] | [INFO] [stderr] 83 | write_stream.send(Message::new_message(t, data * data)); [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_must_use)]` on by default [INFO] [stderr] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stderr] [INFO] [stderr] warning: 3 warnings emitted [INFO] [stderr] [INFO] [stderr] warning: unused import: `operators::MapOperator` [INFO] [stderr] --> tests/loop_test.rs:5:21 [INFO] [stderr] | [INFO] [stderr] 5 | message::*, operators::MapOperator, stream::WriteStreamT, LoopStream, OperatorConfig, [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` on by default [INFO] [stderr] [INFO] [stderr] warning: 1 warning emitted [INFO] [stderr] [INFO] [stderr] Finished test [unoptimized + debuginfo] target(s) in 0.33s [INFO] [stderr] Running /opt/rustwide/target/debug/deps/erdos-acfa44bcc8377a88 [INFO] [stdout] [INFO] [stdout] running 13 tests [INFO] [stdout] test dataflow::tests::test_callback_and_watermark_callback ... ok [INFO] [stdout] test dataflow::tests::test_multi_stream_callback ... ok [INFO] [stdout] test dataflow::stream::tests::test_write_stream_sendable ... ok [INFO] [stdout] test dataflow::stream::tests::test_write_stream_invalid_send ... ok [INFO] [stdout] test dataflow::stream::tests::test_write_stream_out_of_order_watermark ... ok [INFO] [stdout] test dataflow::stream::tests::test_write_stream_watermark ... ok [INFO] [stdout] test dataflow::tests::test_callback ... ok [INFO] [stdout] test dataflow::tests::test_watermark_callback ... ok [INFO] [stdout] test dataflow::stream::tests::test_write_stream_send ... ok [INFO] [stdout] test dataflow::tests::test_stateful_watermark_callback ... ok [INFO] [stdout] test dataflow::tests::test_stateful_callback ... ok [INFO] [stdout] test dataflow::tests::test_one_read_one_write_callback ... ok [INFO] [stderr] Running /opt/rustwide/target/debug/deps/erdos-de6ffe2ed8ed27ad [INFO] [stdout] test dataflow::tests::test_multi_stream_stateful_callback ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 13 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Running /opt/rustwide/target/debug/deps/experiment_throughput-157ce55838439509 [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Running /opt/rustwide/target/debug/deps/experiment_throughput_driver-b0212ac1b348823d [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stderr] Running /opt/rustwide/target/debug/deps/driver_test-4e1813ef50c82399 [INFO] [stderr] Running /opt/rustwide/target/debug/deps/inter_thread_test-a70b797e044fee47 [INFO] [stdout] [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] running 4 tests [INFO] [stderr] Apr 19 18:20:06.916 DEBG Ingest stream: sending TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [0] }, data: 0 }) [INFO] [stderr] Apr 19 18:20:06.946 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:06.948 DEBG Executing operator 9d6c5915-6f23-13dc-9890-b4bc7a4627cb on node 0 [INFO] [stderr] Apr 19 18:20:06.958 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:06.958 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:06.959 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:06.961 DEBG Executing operator 97944689-ce67-a82c-c506-8ba4659991b6 on node 0 [INFO] [stderr] Apr 19 18:20:06.990 DEBG Executing operator 97944689-ce67-a82c-c506-8ba4659991b6 on node 0 [INFO] [stderr] Apr 19 18:20:06.991 DEBG Executing operator 9d6c5915-6f23-13dc-9890-b4bc7a4627cb on node 0 [INFO] [stderr] Apr 19 18:20:06.991 DEBG Executing operator 97944689-ce67-a82c-c506-8ba4659991b6 on node 0 [INFO] [stdout] SquareOperator: received 0 [INFO] [stderr] Apr 19 18:20:07.467 DEBG Received Some(TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [0] }, data: 0 })) [INFO] [stdout] SquareOperator: received 1 [INFO] [stderr] Apr 19 18:20:07.467 DEBG Ingest stream: sending TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [1] }, data: 1 }) [INFO] [stderr] Apr 19 18:20:07.467 DEBG Received Some(TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [1] }, data: 1 })) [INFO] [stdout] SquareOperator: received 2 [INFO] [stderr] Apr 19 18:20:07.468 DEBG Ingest stream: sending TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [2] }, data: 2 }) [INFO] [stdout] SquareOperator: received 3 [INFO] [stderr] Apr 19 18:20:07.468 DEBG Received Some(TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [2] }, data: 4 })) [INFO] [stdout] SquareOperator: received 4 [INFO] [stderr] Apr 19 18:20:07.468 DEBG Ingest stream: sending TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [3] }, data: 3 }) [INFO] [stderr] Apr 19 18:20:07.468 DEBG Received Some(TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [3] }, data: 9 })) [INFO] [stderr] Apr 19 18:20:07.468 DEBG Ingest stream: sending TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [4] }, data: 4 }) [INFO] [stderr] Apr 19 18:20:07.468 DEBG Received Some(TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [4] }, data: 16 })) [INFO] [stdout] SendOperator: sending 0 [INFO] [stdout] SendOperator: sending 1 [INFO] [stdout] SendOperator: sending 2 [INFO] [stdout] SendOperator: sending 3 [INFO] [stdout] SendOperator: sending 4 [INFO] [stdout] RecvOperator: received 0 [INFO] [stdout] RecvOperator: received 1 [INFO] [stdout] RecvOperator: received 2 [INFO] [stdout] RecvOperator: received 3 [INFO] [stdout] RecvOperator: received 4 [INFO] [stdout] SendOperator: sending 0 [INFO] [stdout] SendOperator: sending 1 [INFO] [stdout] SendOperator: sending 2 [INFO] [stdout] SendOperator: sending 3 [INFO] [stdout] SendOperator: sending 4 [INFO] [stdout] RecvOperator: received 0 [INFO] [stdout] RecvOperator: received 1 [INFO] [stdout] RecvOperator: received 2 [INFO] [stdout] RecvOperator: received 3 [INFO] [stdout] RecvOperator: received 4 [INFO] [stdout] test test_inter_thread ... ok [INFO] [stdout] test test_ingest ... ok [INFO] [stdout] test test_ingest_extract ... ok [INFO] [stdout] test test_extract ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 4 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stderr] Running /opt/rustwide/target/debug/deps/loop_test-d31b705be7b8bb27 [INFO] [stdout] [INFO] [stdout] running 1 test [INFO] [stderr] Apr 19 18:20:08.518 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:08.519 DEBG Executing operator 9d6c5915-6f23-13dc-9890-b4bc7a4627cb on node 0 [INFO] [stdout] LoopOp: sending TimestampedData(TimestampedData { timestamp: IntTimestamp { time: [0] }, data: 0 }) [INFO] [stdout] LoopOp: received TimestampedData { timestamp: IntTimestamp { time: [0] }, data: 0 } [INFO] [stdout] LoopOp: sending TimestampedData { timestamp: IntTimestamp { time: [1] }, data: 1 } [INFO] [stdout] LoopOp: received TimestampedData { timestamp: IntTimestamp { time: [1] }, data: 1 } [INFO] [stdout] LoopOp: sending TimestampedData { timestamp: IntTimestamp { time: [2] }, data: 2 } [INFO] [stdout] LoopOp: received TimestampedData { timestamp: IntTimestamp { time: [2] }, data: 2 } [INFO] [stdout] LoopOp: sending TimestampedData { timestamp: IntTimestamp { time: [3] }, data: 3 } [INFO] [stdout] LoopOp: received TimestampedData { timestamp: IntTimestamp { time: [3] }, data: 3 } [INFO] [stdout] LoopOp: sending TimestampedData { timestamp: IntTimestamp { time: [4] }, data: 4 } [INFO] [stdout] LoopOp: received TimestampedData { timestamp: IntTimestamp { time: [4] }, data: 4 } [INFO] [stdout] LoopOp: sending TimestampedData { timestamp: IntTimestamp { time: [5] }, data: 5 } [INFO] [stdout] test test_loop ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 1 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stderr] Running /opt/rustwide/target/debug/deps/watermark_test-f9f646d0807eff71 [INFO] [stdout] [INFO] [stdout] running 2 tests [INFO] [stderr] Apr 19 18:20:10.534 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:10.542 DEBG Starting node 0 [INFO] [stderr] Apr 19 18:20:10.542 DEBG Executing operator 97944689-ce67-a82c-c506-8ba4659991b6 on node 0 [INFO] [stderr] Apr 19 18:20:10.542 DEBG Executing operator a1a1bc90-4811-2c4b-0580-1b8b3546c0ab on node 0 [INFO] [stderr] Apr 19 18:20:10.546 DEBG Executing operator a7015556-7321-9352-b74e-a6694460cab1 on node 0 [INFO] [stderr] Apr 19 18:20:10.570 DEBG Executing operator 97944689-ce67-a82c-c506-8ba4659991b6 on node 0 [INFO] [stderr] Apr 19 18:20:10.590 DEBG Executing operator a1a1bc90-4811-2c4b-0580-1b8b3546c0ab on node 0 [INFO] [stderr] Apr 19 18:20:10.610 DEBG Executing operator a7015556-7321-9352-b74e-a6694460cab1 on node 0 [INFO] [stdout] SendOperator: sending 0 [INFO] [stdout] SendOperator: sending 1 [INFO] [stdout] SendOperator: sending 2 [INFO] [stdout] SendOperator: sending 3 [INFO] [stdout] SendOperator: sending 4 [INFO] [stdout] SendOperator: sending 0 [INFO] [stdout] SendOperator: sending 1 [INFO] [stdout] SendOperator: sending 2 [INFO] [stdout] SendOperator: sending 3 [INFO] [stdout] SendOperator: sending 4 [INFO] [stdout] RecvOperator: received watermark: IntTimestamp { time: [0] } [INFO] [stdout] RecvOperator: received watermark: IntTimestamp { time: [1] } [INFO] [stdout] RecvOperator: received watermark: IntTimestamp { time: [2] } [INFO] [stdout] RecvOperator: received watermark: IntTimestamp { time: [3] } [INFO] [stdout] RecvOperator: received watermark: IntTimestamp { time: [4] } [INFO] [stdout] test test_no_flow_watermarks ... ok [INFO] [stdout] test test_flow_watermarks ... ok [INFO] [stdout] [INFO] [stdout] test result: ok. 2 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] [stderr] Doc-tests erdos [INFO] [stdout] [INFO] [stdout] running 0 tests [INFO] [stdout] [INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out [INFO] [stdout] [INFO] running `"docker" "inspect" "8158d6db36210d82423cf9ecb9b5417e83d913e07b8196e5a5877a2bddd665d5"` [INFO] running `"docker" "rm" "-f" "8158d6db36210d82423cf9ecb9b5417e83d913e07b8196e5a5877a2bddd665d5"` [INFO] [stdout] 8158d6db36210d82423cf9ecb9b5417e83d913e07b8196e5a5877a2bddd665d5