[INFO] cloning repository https://github.com/shenxushenxu/data-lake [INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/shenxushenxu/data-lake" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fshenxushenxu%2Fdata-lake", kill_on_drop: false }` [INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fshenxushenxu%2Fdata-lake'... [INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }` [INFO] [stdout] 4eca969420f7cf59c60000accb57e4942dbd0b5b [INFO] checking shenxushenxu/data-lake against master#9e293ae9f8abecb0be5105787d181518c9012a19 for pr-146440-1 [INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fshenxushenxu%2Fdata-lake" "/workspace/builds/worker-3-tc1/source", kill_on_drop: false }` [INFO] [stderr] Cloning into '/workspace/builds/worker-3-tc1/source'... [INFO] [stderr] done. [INFO] started tweaking git repo https://github.com/shenxushenxu/data-lake [INFO] finished tweaking git repo https://github.com/shenxushenxu/data-lake [INFO] tweaked toml for git repo https://github.com/shenxushenxu/data-lake written to /workspace/builds/worker-3-tc1/source/Cargo.toml [INFO] validating manifest of git repo https://github.com/shenxushenxu/data-lake on toolchain 9e293ae9f8abecb0be5105787d181518c9012a19 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+9e293ae9f8abecb0be5105787d181518c9012a19" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate git repo https://github.com/shenxushenxu/data-lake already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+9e293ae9f8abecb0be5105787d181518c9012a19" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] warning: virtual workspace defaulting to `resolver = "1"` despite one or more workspace members being on edition 2024 which implies `resolver = "3"` [INFO] [stderr] | [INFO] [stderr] = note: to keep the current resolver, specify `workspace.resolver = "1"` in the workspace root's manifest [INFO] [stderr] = note: to use the edition 2024 resolver, specify `workspace.resolver = "3"` in the workspace root's manifest [INFO] [stderr] = note: for more details see https://doc.rust-lang.org/cargo/reference/resolver.html#resolver-versions [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded bitflags v2.8.0 [INFO] [stderr] Downloaded wit-bindgen-rt v0.33.0 [INFO] [stderr] Downloaded getrandom v0.3.1 [INFO] [stderr] Downloaded uuid v1.14.0 [INFO] [stderr] Downloaded mimalloc v0.1.47 [INFO] [stderr] Downloaded simple_logger v5.0.0 [INFO] [stderr] Downloaded colored v2.2.0 [INFO] [stderr] Downloaded ryu v1.0.19 [INFO] [stderr] Downloaded snap v1.1.1 [INFO] [stderr] Downloaded once_cell v1.20.3 [INFO] [stderr] Downloaded unicode-ident v1.0.16 [INFO] [stderr] Downloaded proc-macro2 v1.0.93 [INFO] [stderr] Downloaded miniz_oxide v0.8.4 [INFO] [stderr] Downloaded wasi v0.13.3+wasi-0.2.2 [INFO] [stderr] Downloaded socket2 v0.6.0 [INFO] [stderr] Downloaded io-uring v0.7.9 [INFO] [stderr] Downloaded bytes v1.10.0 [INFO] [stderr] Downloaded libmimalloc-sys v0.1.43 [INFO] [stderr] Downloaded syn v2.0.98 [INFO] [stderr] Downloaded tokio v1.47.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+9e293ae9f8abecb0be5105787d181518c9012a19" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 29ff9916db7ae3d5086082e5484355fabe56797a3d6e62552788245cd7ae23e8 [INFO] running `Command { std: "docker" "start" "-a" "29ff9916db7ae3d5086082e5484355fabe56797a3d6e62552788245cd7ae23e8", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "29ff9916db7ae3d5086082e5484355fabe56797a3d6e62552788245cd7ae23e8", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "29ff9916db7ae3d5086082e5484355fabe56797a3d6e62552788245cd7ae23e8", kill_on_drop: false }` [INFO] [stdout] 29ff9916db7ae3d5086082e5484355fabe56797a3d6e62552788245cd7ae23e8 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3-tc1/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" "RUSTDOCFLAGS=--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:d429b63d4308055ea97f60fb1d3dfca48854a00942f1bd2ad806beaf015945ec" "/opt/rustwide/cargo-home/bin/cargo" "+9e293ae9f8abecb0be5105787d181518c9012a19" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 5344ca3a06eb5ecf106b35803ae4040ac203aba1796c911372c52a185ef80a6a [INFO] running `Command { std: "docker" "start" "-a" "5344ca3a06eb5ecf106b35803ae4040ac203aba1796c911372c52a185ef80a6a", kill_on_drop: false }` [INFO] [stderr] warning: virtual workspace defaulting to `resolver = "1"` despite one or more workspace members being on edition 2024 which implies `resolver = "3"` [INFO] [stderr] | [INFO] [stderr] = note: to keep the current resolver, specify `workspace.resolver = "1"` in the workspace root's manifest [INFO] [stderr] = note: to use the edition 2024 resolver, specify `workspace.resolver = "3"` in the workspace root's manifest [INFO] [stderr] = note: for more details see https://doc.rust-lang.org/cargo/reference/resolver.html#resolver-versions [INFO] [stderr] Compiling libc v0.2.174 [INFO] [stderr] Compiling proc-macro2 v1.0.93 [INFO] [stderr] Compiling unicode-ident v1.0.16 [INFO] [stderr] Compiling getrandom v0.3.1 [INFO] [stderr] Compiling zerocopy v0.8.26 [INFO] [stderr] Compiling lock_api v0.4.12 [INFO] [stderr] Compiling parking_lot_core v0.9.10 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Checking smallvec v1.14.0 [INFO] [stderr] Compiling num-conv v0.1.0 [INFO] [stderr] Checking itoa v1.0.14 [INFO] [stderr] Checking log v0.4.27 [INFO] [stderr] Compiling time-core v0.1.4 [INFO] [stderr] Checking deranged v0.4.0 [INFO] [stderr] Compiling time-macros v0.2.22 [INFO] [stderr] Compiling snap v1.1.1 [INFO] [stderr] Compiling serde_json v1.0.140 [INFO] [stderr] Checking once_cell v1.20.3 [INFO] [stderr] Compiling quote v1.0.38 [INFO] [stderr] Checking colored v2.2.0 [INFO] [stderr] Checking hashbrown v0.14.5 [INFO] [stderr] Checking bytes v1.10.0 [INFO] [stderr] Checking ryu v1.0.19 [INFO] [stderr] Compiling syn v2.0.98 [INFO] [stderr] Checking socket2 v0.6.0 [INFO] [stderr] Checking rand_core v0.9.3 [INFO] [stderr] Checking mio v1.0.3 [INFO] [stderr] Checking parking_lot v0.12.3 [INFO] [stderr] Checking signal-hook-registry v1.4.2 [INFO] [stderr] Checking pin-project-lite v0.2.16 [INFO] [stderr] Checking dashmap v6.1.0 [INFO] [stderr] Checking uuid v1.14.0 [INFO] [stderr] Checking memmap2 v0.9.5 [INFO] [stderr] Compiling cc v1.2.30 [INFO] [stderr] Checking regex-syntax v0.8.5 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Checking anstream v0.6.18 [INFO] [stderr] Checking humantime v2.1.0 [INFO] [stderr] Checking time v0.3.41 [INFO] [stderr] Checking iana-time-zone v0.1.63 [INFO] [stderr] Checking either v1.15.0 [INFO] [stderr] Compiling ahash v0.8.12 [INFO] [stderr] Checking rayon v1.10.0 [INFO] [stderr] Checking chrono v0.4.41 [INFO] [stderr] Checking simple_logger v5.0.0 [INFO] [stderr] Checking ppv-lite86 v0.2.21 [INFO] [stderr] Checking rand_chacha v0.9.0 [INFO] [stderr] Checking regex-automata v0.4.9 [INFO] [stderr] Compiling libmimalloc-sys v0.1.43 [INFO] [stderr] Checking rand v0.9.1 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Checking mimalloc v0.1.47 [INFO] [stderr] Checking regex v1.11.1 [INFO] [stderr] Checking tokio v1.47.0 [INFO] [stderr] Checking env_filter v0.1.3 [INFO] [stderr] Checking env_logger v0.11.6 [INFO] [stderr] Checking bincode v1.3.3 [INFO] [stderr] Checking entity_lib v0.1.0 (/opt/rustwide/workdir/data-lake-lib) [INFO] [stdout] warning: unused import: `write` [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:3:16 [INFO] [stdout] | [INFO] [stdout] 3 | use std::fmt::{write, Display, Formatter}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::entity::DataLakeEntity::SlaveBatchData` [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use crate::entity::DataLakeEntity::SlaveBatchData; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `string` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:9:5 [INFO] [stdout] | [INFO] [stdout] 9 | string, [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `String` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_camel_case_types)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `int` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | int, [INFO] [stdout] | ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Int` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `float` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | float, [INFO] [stdout] | ^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Float` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `boolean` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | boolean, [INFO] [stdout] | ^^^^^^^ help: convert the identifier to upper camel case: `Boolean` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `long` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | long, [INFO] [stdout] | ^^^^ help: convert the identifier to upper camel case: `Long` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `PRIMARY_KEY` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | PRIMARY_KEY, [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `PrimaryKey` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `NOT_NULL` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:34:5 [INFO] [stdout] | [INFO] [stdout] 34 | NOT_NULL, [INFO] [stdout] | ^^^^^^^^ help: convert the identifier to upper camel case: `NotNull` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `sql` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:114:5 [INFO] [stdout] | [INFO] [stdout] 114 | sql(String), [INFO] [stdout] | ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Sql` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `stream_read` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:115:5 [INFO] [stdout] | [INFO] [stdout] 115 | stream_read(MasterStreamRead), [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `batch_insert` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:116:5 [INFO] [stdout] | [INFO] [stdout] 116 | batch_insert, [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `table` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:198:5 [INFO] [stdout] | [INFO] [stdout] 198 | table(String), [INFO] [stdout] | ^^^^^ help: convert the identifier to upper camel case: `Table` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `column` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:199:5 [INFO] [stdout] | [INFO] [stdout] 199 | column(Vec), [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Column` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `term` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:200:5 [INFO] [stdout] | [INFO] [stdout] 200 | term(HashMap), [INFO] [stdout] | ^^^^ help: convert the identifier to upper camel case: `Term` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `gt` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:201:5 [INFO] [stdout] | [INFO] [stdout] 201 | gt(HashMap), [INFO] [stdout] | ^^ help: convert the identifier to upper camel case: `Gt` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `lt` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:202:5 [INFO] [stdout] | [INFO] [stdout] 202 | lt(HashMap), [INFO] [stdout] | ^^ help: convert the identifier to upper camel case: `Lt` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `BufWriter` [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:12:46 [INFO] [stdout] | [INFO] [stdout] 12 | use tokio::io::{AsyncReadExt, AsyncWriteExt, BufWriter}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `create` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:34:5 [INFO] [stdout] | [INFO] [stdout] 34 | create(SlaveCreate), [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Create` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `query` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:35:5 [INFO] [stdout] | [INFO] [stdout] 35 | query(QueryMessage), [INFO] [stdout] | ^^^^^ help: convert the identifier to upper camel case: `Query` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `insert` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:36:5 [INFO] [stdout] | [INFO] [stdout] 36 | insert(Insert), [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Insert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `compress_table` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:37:5 [INFO] [stdout] | [INFO] [stdout] 37 | compress_table(String), [INFO] [stdout] | ^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CompressTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `stream_read` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:38:5 [INFO] [stdout] | [INFO] [stdout] 38 | stream_read(StreamReadStruct), [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `batch_insert` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:39:5 [INFO] [stdout] | [INFO] [stdout] 39 | batch_insert(TableStructure), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `drop_table` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:40:5 [INFO] [stdout] | [INFO] [stdout] 40 | drop_table(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `follower_replicas_sync` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:41:5 [INFO] [stdout] | [INFO] [stdout] 41 | follower_replicas_sync(ReplicasSyncStruct), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `FollowerReplicasSync` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `leader_replicas_sync` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:42:5 [INFO] [stdout] | [INFO] [stdout] 42 | leader_replicas_sync(SyncMessage), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `LeaderReplicasSync` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `max_offset` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:43:5 [INFO] [stdout] | [INFO] [stdout] 43 | max_offset(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `MaxOffset` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `CREATE_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | CREATE_TABLE(TableStructure), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CreateTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `SELECT_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | SELECT_TABLE(QueryMessage), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `SelectTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `ALTER_OROP` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:9:5 [INFO] [stdout] | [INFO] [stdout] 9 | ALTER_OROP((String, String)), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `AlterOrop` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `ALTER_ADD` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | ALTER_ADD((String, String, String, String, String)), [INFO] [stdout] | ^^^^^^^^^ help: convert the identifier to upper camel case: `AlterAdd` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `DESC_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | DESC_TABLE(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `DescTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `SHOW_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | SHOW_TABLE, [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `ShowTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `COMPRESS_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | COMPRESS_TABLE(String), [INFO] [stdout] | ^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CompressTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `DROP_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | DROP_TABLE(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `MAX_OFFSET` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | MAX_OFFSET(String) [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `MaxOffset` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::function::vec_trait::VecPutVec` [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use crate::function::vec_trait::VecPutVec; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::fmt::format` [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | use std::fmt::format; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Deserialize` and `Serialize` [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:9:13 [INFO] [stdout] | [INFO] [stdout] 9 | use serde::{Deserialize, Serialize}; [INFO] [stdout] | ^^^^^^^^^^^ ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::SeekFrom` [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use std::io::SeekFrom; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::path::Path` [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use std::path::Path; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `BufWriter` [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:7:60 [INFO] [stdout] | [INFO] [stdout] 7 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt, BufWriter}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary trailing semicolon [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:81:92 [INFO] [stdout] | [INFO] [stdout] 81 | ... let data_position = temp_file.stream_position().await?;; [INFO] [stdout] | ^ help: remove this semicolon [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(redundant_semicolons)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary trailing semicolon [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:107:88 [INFO] [stdout] | [INFO] [stdout] 107 | ... let data_position = temp_file.stream_position().await?;; [INFO] [stdout] | ^ help: remove this semicolon [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::path::Path` [INFO] [stdout] --> data-lake-lib/src/function/table_structure.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::path::Path; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `write` [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:3:16 [INFO] [stdout] | [INFO] [stdout] 3 | use std::fmt::{write, Display, Formatter}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::entity::DataLakeEntity::SlaveBatchData` [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use crate::entity::DataLakeEntity::SlaveBatchData; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `string` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:9:5 [INFO] [stdout] | [INFO] [stdout] 9 | string, [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `String` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_camel_case_types)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `int` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | int, [INFO] [stdout] | ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Int` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `float` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | float, [INFO] [stdout] | ^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Float` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `boolean` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | boolean, [INFO] [stdout] | ^^^^^^^ help: convert the identifier to upper camel case: `Boolean` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `long` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | long, [INFO] [stdout] | ^^^^ help: convert the identifier to upper camel case: `Long` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `PRIMARY_KEY` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | PRIMARY_KEY, [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `PrimaryKey` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `NOT_NULL` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:34:5 [INFO] [stdout] | [INFO] [stdout] 34 | NOT_NULL, [INFO] [stdout] | ^^^^^^^^ help: convert the identifier to upper camel case: `NotNull` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `sql` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:114:5 [INFO] [stdout] | [INFO] [stdout] 114 | sql(String), [INFO] [stdout] | ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Sql` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `stream_read` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:115:5 [INFO] [stdout] | [INFO] [stdout] 115 | stream_read(MasterStreamRead), [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `batch_insert` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:116:5 [INFO] [stdout] | [INFO] [stdout] 116 | batch_insert, [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `table` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:198:5 [INFO] [stdout] | [INFO] [stdout] 198 | table(String), [INFO] [stdout] | ^^^^^ help: convert the identifier to upper camel case: `Table` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `column` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:199:5 [INFO] [stdout] | [INFO] [stdout] 199 | column(Vec), [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Column` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `term` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:200:5 [INFO] [stdout] | [INFO] [stdout] 200 | term(HashMap), [INFO] [stdout] | ^^^^ help: convert the identifier to upper camel case: `Term` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `gt` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:201:5 [INFO] [stdout] | [INFO] [stdout] 201 | gt(HashMap), [INFO] [stdout] | ^^ help: convert the identifier to upper camel case: `Gt` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `lt` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/MasterEntity.rs:202:5 [INFO] [stdout] | [INFO] [stdout] 202 | lt(HashMap), [INFO] [stdout] | ^^ help: convert the identifier to upper camel case: `Lt` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `BufWriter` [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:12:46 [INFO] [stdout] | [INFO] [stdout] 12 | use tokio::io::{AsyncReadExt, AsyncWriteExt, BufWriter}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `create` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:34:5 [INFO] [stdout] | [INFO] [stdout] 34 | create(SlaveCreate), [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Create` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `query` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:35:5 [INFO] [stdout] | [INFO] [stdout] 35 | query(QueryMessage), [INFO] [stdout] | ^^^^^ help: convert the identifier to upper camel case: `Query` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `insert` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:36:5 [INFO] [stdout] | [INFO] [stdout] 36 | insert(Insert), [INFO] [stdout] | ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Insert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `compress_table` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:37:5 [INFO] [stdout] | [INFO] [stdout] 37 | compress_table(String), [INFO] [stdout] | ^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CompressTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `stream_read` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:38:5 [INFO] [stdout] | [INFO] [stdout] 38 | stream_read(StreamReadStruct), [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `batch_insert` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:39:5 [INFO] [stdout] | [INFO] [stdout] 39 | batch_insert(TableStructure), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `drop_table` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:40:5 [INFO] [stdout] | [INFO] [stdout] 40 | drop_table(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `follower_replicas_sync` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:41:5 [INFO] [stdout] | [INFO] [stdout] 41 | follower_replicas_sync(ReplicasSyncStruct), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `FollowerReplicasSync` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `leader_replicas_sync` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:42:5 [INFO] [stdout] | [INFO] [stdout] 42 | leader_replicas_sync(SyncMessage), [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `LeaderReplicasSync` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `max_offset` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:43:5 [INFO] [stdout] | [INFO] [stdout] 43 | max_offset(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `MaxOffset` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `CREATE_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | CREATE_TABLE(TableStructure), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CreateTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `SELECT_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | SELECT_TABLE(QueryMessage), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `SelectTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `ALTER_OROP` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:9:5 [INFO] [stdout] | [INFO] [stdout] 9 | ALTER_OROP((String, String)), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `AlterOrop` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `ALTER_ADD` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | ALTER_ADD((String, String, String, String, String)), [INFO] [stdout] | ^^^^^^^^^ help: convert the identifier to upper camel case: `AlterAdd` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `DESC_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | DESC_TABLE(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `DescTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `SHOW_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | SHOW_TABLE, [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `ShowTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `COMPRESS_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | COMPRESS_TABLE(String), [INFO] [stdout] | ^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CompressTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `DROP_TABLE` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | DROP_TABLE(String), [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `MAX_OFFSET` should have an upper camel case name [INFO] [stdout] --> data-lake-lib/src/entity/DaqlEntity.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | MAX_OFFSET(String) [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to upper camel case: `MaxOffset` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::function::vec_trait::VecPutVec` [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use crate::function::vec_trait::VecPutVec; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::fmt::format` [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | use std::fmt::format; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Deserialize` and `Serialize` [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:9:13 [INFO] [stdout] | [INFO] [stdout] 9 | use serde::{Deserialize, Serialize}; [INFO] [stdout] | ^^^^^^^^^^^ ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::entity::MasterEntity::Statement` [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use crate::entity::MasterEntity::Statement; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::SeekFrom` [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use std::io::SeekFrom; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::path::Path` [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use std::path::Path; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `BufWriter` [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:7:60 [INFO] [stdout] | [INFO] [stdout] 7 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt, BufWriter}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary trailing semicolon [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:81:92 [INFO] [stdout] | [INFO] [stdout] 81 | ... let data_position = temp_file.stream_position().await?;; [INFO] [stdout] | ^ help: remove this semicolon [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(redundant_semicolons)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary trailing semicolon [INFO] [stdout] --> data-lake-lib/src/function/read_function.rs:107:88 [INFO] [stdout] | [INFO] [stdout] 107 | ... let data_position = temp_file.stream_position().await?;; [INFO] [stdout] | ^ help: remove this semicolon [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::path::Path` [INFO] [stdout] --> data-lake-lib/src/function/table_structure.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::path::Path; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-lib/src/function/table_structure.rs:14:9 [INFO] [stdout] | [INFO] [stdout] 14 | let mut mmap = unsafe { Mmap::map(&file)? }; [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:112:13 [INFO] [stdout] | [INFO] [stdout] 112 | let mut path_index = self.data_path_index; [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:170:13 [INFO] [stdout] | [INFO] [stdout] 170 | let mut slave_config = SLAVE_CONFIG.lock().await; [INFO] [stdout] | ----^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-lib/src/function/table_structure.rs:14:9 [INFO] [stdout] | [INFO] [stdout] 14 | let mut mmap = unsafe { Mmap::map(&file)? }; [INFO] [stdout] | ----^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:112:13 [INFO] [stdout] | [INFO] [stdout] 112 | let mut path_index = self.data_path_index; [INFO] [stdout] | ----^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:170:13 [INFO] [stdout] | [INFO] [stdout] 170 | let mut slave_config = SLAVE_CONFIG.lock().await; [INFO] [stdout] | ----^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `e` [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:339:20 [INFO] [stdout] | [INFO] [stdout] 339 | if let Err(e) = self.tcp_stream.write_i32(value).await { [INFO] [stdout] | ^ help: if this is intentional, prefix it with an underscore: `_e` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `e` [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:363:20 [INFO] [stdout] | [INFO] [stdout] 363 | if let Err(e) =self.tcp_stream.write_all(value).await { [INFO] [stdout] | ^ help: if this is intentional, prefix it with an underscore: `_e` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `index` [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:19:32 [INFO] [stdout] | [INFO] [stdout] 19 | pub fn get_line(&mut self, index: usize) -> Vec<&'a str> { [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_index` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `e` [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:339:20 [INFO] [stdout] | [INFO] [stdout] 339 | if let Err(e) = self.tcp_stream.write_i32(value).await { [INFO] [stdout] | ^ help: if this is intentional, prefix it with an underscore: `_e` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `e` [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:363:20 [INFO] [stdout] | [INFO] [stdout] 363 | if let Err(e) =self.tcp_stream.write_all(value).await { [INFO] [stdout] | ^ help: if this is intentional, prefix it with an underscore: `_e` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `index` [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:19:32 [INFO] [stdout] | [INFO] [stdout] 19 | pub fn get_line(&mut self, index: usize) -> Vec<&'a str> { [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_index` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `metadata_file` is never read [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:74:5 [INFO] [stdout] | [INFO] [stdout] 71 | pub struct SlaveCacheStruct { [INFO] [stdout] | ---------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 74 | metadata_file: File, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `byte_ptr` and `batch_data_ptr` are never read [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:396:5 [INFO] [stdout] | [INFO] [stdout] 395 | pub struct PtrByteBatchData { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 396 | byte_ptr: Option<&'static mut Vec>, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 397 | batch_data_ptr: Option<&'static mut BatchData<'static>>, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `MasterEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:1:9 [INFO] [stdout] | [INFO] [stdout] 1 | pub mod MasterEntity; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case: `master_entity` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_snake_case)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `SlaveEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:2:9 [INFO] [stdout] | [INFO] [stdout] 2 | pub mod SlaveEntity; [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to snake case: `slave_entity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `Error` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:3:9 [INFO] [stdout] | [INFO] [stdout] 3 | pub mod Error; [INFO] [stdout] | ^^^^^ help: convert the identifier to snake case: `error` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `DaqlEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:4:9 [INFO] [stdout] | [INFO] [stdout] 4 | pub mod DaqlEntity; [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to snake case: `daql_entity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `DataLakeEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:6:9 [INFO] [stdout] | [INFO] [stdout] 6 | pub mod DataLakeEntity; [INFO] [stdout] | ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `data_lake_entity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:202:31 [INFO] [stdout] | [INFO] [stdout] 202 | pub fn deserialize(bytes: &[u8]) -> DataStructure { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] = note: `#[warn(mismatched_lifetime_syntaxes)]` on by default [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 202 | pub fn deserialize(bytes: &[u8]) -> DataStructure<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:76:33 [INFO] [stdout] | [INFO] [stdout] 76 | pub fn entity_decode(bytes: &[u8]) -> Result { [INFO] [stdout] | ^^^^^ ^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 76 | pub fn entity_decode(bytes: &[u8]) -> Result, DataLakeError> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:304:31 [INFO] [stdout] | [INFO] [stdout] 304 | pub fn deserialize(bytes: &[u8]) -> Result { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 304 | pub fn deserialize(bytes: &[u8]) -> Result, DataLakeError> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `BufferObject` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:1:9 [INFO] [stdout] | [INFO] [stdout] 1 | pub mod BufferObject; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case: `buffer_object` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `RandomNumber` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:2:9 [INFO] [stdout] | [INFO] [stdout] 2 | pub mod RandomNumber; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case: `random_number` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `metadata_file` is never read [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:74:5 [INFO] [stdout] | [INFO] [stdout] 71 | pub struct SlaveCacheStruct { [INFO] [stdout] | ---------------- field in this struct [INFO] [stdout] ... [INFO] [stdout] 74 | metadata_file: File, [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: fields `byte_ptr` and `batch_data_ptr` are never read [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:396:5 [INFO] [stdout] | [INFO] [stdout] 395 | pub struct PtrByteBatchData { [INFO] [stdout] | ---------------- fields in this struct [INFO] [stdout] 396 | byte_ptr: Option<&'static mut Vec>, [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] 397 | batch_data_ptr: Option<&'static mut BatchData<'static>>, [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `MasterEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:1:9 [INFO] [stdout] | [INFO] [stdout] 1 | pub mod MasterEntity; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case: `master_entity` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_snake_case)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `SlaveEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:2:9 [INFO] [stdout] | [INFO] [stdout] 2 | pub mod SlaveEntity; [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to snake case: `slave_entity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `Error` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:3:9 [INFO] [stdout] | [INFO] [stdout] 3 | pub mod Error; [INFO] [stdout] | ^^^^^ help: convert the identifier to snake case: `error` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `DaqlEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:4:9 [INFO] [stdout] | [INFO] [stdout] 4 | pub mod DaqlEntity; [INFO] [stdout] | ^^^^^^^^^^ help: convert the identifier to snake case: `daql_entity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `DataLakeEntity` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/entity/mod.rs:6:9 [INFO] [stdout] | [INFO] [stdout] 6 | pub mod DataLakeEntity; [INFO] [stdout] | ^^^^^^^^^^^^^^ help: convert the identifier to snake case: `data_lake_entity` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> data-lake-lib/src/entity/SlaveEntity.rs:202:31 [INFO] [stdout] | [INFO] [stdout] 202 | pub fn deserialize(bytes: &[u8]) -> DataStructure { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] = note: `#[warn(mismatched_lifetime_syntaxes)]` on by default [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 202 | pub fn deserialize(bytes: &[u8]) -> DataStructure<'_> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:76:33 [INFO] [stdout] | [INFO] [stdout] 76 | pub fn entity_decode(bytes: &[u8]) -> Result { [INFO] [stdout] | ^^^^^ ^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 76 | pub fn entity_decode(bytes: &[u8]) -> Result, DataLakeError> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: hiding a lifetime that's elided elsewhere is confusing [INFO] [stdout] --> data-lake-lib/src/entity/DataLakeEntity.rs:304:31 [INFO] [stdout] | [INFO] [stdout] 304 | pub fn deserialize(bytes: &[u8]) -> Result { [INFO] [stdout] | ^^^^^ ^^^^^^^^^^^ the same lifetime is hidden here [INFO] [stdout] | | [INFO] [stdout] | the lifetime is elided here [INFO] [stdout] | [INFO] [stdout] = help: the same lifetime is referred to in inconsistent ways, making the signature confusing [INFO] [stdout] help: use `'_` for type paths [INFO] [stdout] | [INFO] [stdout] 304 | pub fn deserialize(bytes: &[u8]) -> Result, DataLakeError> { [INFO] [stdout] | ++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `BufferObject` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:1:9 [INFO] [stdout] | [INFO] [stdout] 1 | pub mod BufferObject; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case: `buffer_object` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: module `RandomNumber` should have a snake case name [INFO] [stdout] --> data-lake-lib/src/function/mod.rs:2:9 [INFO] [stdout] | [INFO] [stdout] 2 | pub mod RandomNumber; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case: `random_number` [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Checking daql_analysis v0.1.0 (/opt/rustwide/workdir/daql_analysis) [INFO] [stderr] Checking slave v0.1.0 (/opt/rustwide/workdir/slave) [INFO] [stderr] Checking data-lake-client v0.1.0 (/opt/rustwide/workdir/data-lake-client) [INFO] [stdout] warning: unused import: `log::log` [INFO] [stdout] --> slave/src/controls/compress_table.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use log::log; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> slave/src/controls/insert_data.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::SeekFrom` [INFO] [stdout] --> slave/src/controls/insert_data.rs:2:5 [INFO] [stdout] | [INFO] [stdout] 2 | use std::io::SeekFrom; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::LazyLock` [INFO] [stdout] --> slave/src/controls/insert_data.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use std::sync::LazyLock; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::MmapMut` [INFO] [stdout] --> slave/src/controls/insert_data.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use memmap2::MmapMut; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `snap::raw::Encoder` [INFO] [stdout] --> slave/src/controls/insert_data.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use snap::raw::Encoder; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::fs::OpenOptions` [INFO] [stdout] --> slave/src/controls/insert_data.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use tokio::fs::OpenOptions; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AsyncReadExt`, `AsyncSeekExt`, and `AsyncWriteExt` [INFO] [stdout] --> slave/src/controls/insert_data.rs:7:17 [INFO] [stdout] | [INFO] [stdout] 7 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::sync::Mutex` [INFO] [stdout] --> slave/src/controls/insert_data.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | use tokio::sync::Mutex; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `DATA_FILE_EXTENSION`, `INDEX_FILE_EXTENSION`, `LOG_FILE`, and `METADATA_LOG` [INFO] [stdout] --> slave/src/controls/insert_data.rs:9:42 [INFO] [stdout] | [INFO] [stdout] 9 | use entity_lib::entity::const_property::{DATA_FILE_EXTENSION, INDEX_FILE_EXTENSION, LOG_FILE, METADATA_LOG}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::DaqlEntity::DaqlType::COMPRESS_TABLE` [INFO] [stdout] --> slave/src/controls/insert_data.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use entity_lib::entity::DaqlEntity::DaqlType::COMPRESS_TABLE; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::Error::DataLakeError` [INFO] [stdout] --> slave/src/controls/insert_data.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use entity_lib::entity::Error::DataLakeError; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::MasterEntity::Insert` [INFO] [stdout] --> slave/src/controls/insert_data.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use entity_lib::entity::MasterEntity::Insert; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `DataStructure`, `IndexStruct`, and `SlaveCacheStruct` [INFO] [stdout] --> slave/src/controls/insert_data.rs:13:39 [INFO] [stdout] | [INFO] [stdout] 13 | use entity_lib::entity::SlaveEntity::{DataStructure, IndexStruct, SlaveCacheStruct}; [INFO] [stdout] | ^^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `DataStructure` [INFO] [stdout] --> slave/src/controls/query_table.rs:2:39 [INFO] [stdout] | [INFO] [stdout] 2 | use entity_lib::entity::SlaveEntity::{DataStructure, QueryMessage}; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::Mmap` [INFO] [stdout] --> slave/src/controls/query_table.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use memmap2::Mmap; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::fmt::format` [INFO] [stdout] --> slave/src/controls/stream_read.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use std::fmt::format; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::panic::Location` [INFO] [stdout] --> slave/src/controls/stream_read.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use std::panic::Location; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> slave/src/controls/stream_read.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Instant` [INFO] [stdout] --> slave/src/controls/stream_read.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | use std::time::Instant; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::io::AsyncSeekExt` [INFO] [stdout] --> slave/src/controls/stream_read.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use tokio::io::AsyncSeekExt; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around assigned value [INFO] [stdout] --> slave/src/controls/stream_read.rs:317:24 [INFO] [stdout] | [INFO] [stdout] 317 | left = (mid + 1); [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_parens)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 317 - left = (mid + 1); [INFO] [stdout] 317 + left = mid + 1 ; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around assigned value [INFO] [stdout] --> slave/src/controls/stream_read.rs:319:25 [INFO] [stdout] | [INFO] [stdout] 319 | right = (mid - 1); [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 319 - right = (mid - 1); [INFO] [stdout] 319 + right = mid - 1 ; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary trailing semicolon [INFO] [stdout] --> slave/src/controls/batch_insert.rs:155:85 [INFO] [stdout] | [INFO] [stdout] 155 | let data_file_len = slave_cache_struct.get_data_file().stream_position().await?;; [INFO] [stdout] | ^ help: remove this semicolon [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(redundant_semicolons)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::error::Error` [INFO] [stdout] --> slave/src/controls/max_offset.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::error::Error; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::controls` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::controls; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `SlaveCacheStruct` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:5:119 [INFO] [stdout] | [INFO] [stdout] 5 | ...ncStruct, ReplicasSyncTcpCacheStruct, ReplicaseSyncData, SlaveCacheStruct, SlaveMessage, SyncMessage}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `MmapMut` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:9:21 [INFO] [stdout] | [INFO] [stdout] 9 | use memmap2::{Mmap, MmapMut}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `LazyLock` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:11:22 [INFO] [stdout] | [INFO] [stdout] 11 | use std::sync::{Arc, LazyLock}; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::net::TcpStream` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | use tokio::net::TcpStream; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `FILE_CACHE_POOL` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:16:42 [INFO] [stdout] | [INFO] [stdout] 16 | use entity_lib::function::BufferObject::{FILE_CACHE_POOL, SLAVE_REPLICAS_SYNC_TCP_CACHE}; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::ErrorKind` [INFO] [stdout] --> slave/src/main.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use std::io::ErrorKind; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Datelike` and `Timelike` [INFO] [stdout] --> slave/src/main.rs:12:14 [INFO] [stdout] | [INFO] [stdout] 12 | use chrono::{Datelike, Timelike}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `error` [INFO] [stdout] --> slave/src/main.rs:17:11 [INFO] [stdout] | [INFO] [stdout] 17 | use log::{error, info}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Instant` [INFO] [stdout] --> slave/src/main.rs:20:27 [INFO] [stdout] | [INFO] [stdout] 20 | use std::time::{Duration, Instant, SystemTime, UNIX_EPOCH}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around assigned value [INFO] [stdout] --> slave/src/main.rs:372:61 [INFO] [stdout] | [INFO] [stdout] 372 | ... let bytes_len = (offset_bytes.len() as i32); [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 372 - let bytes_len = (offset_bytes.len() as i32); [INFO] [stdout] 372 + let bytes_len = offset_bytes.len() as i32 ; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/compress_table.rs:50:9 [INFO] [stdout] | [INFO] [stdout] 50 | let mut log_files = get_list_filename(&table_name).await; [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Statement` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:1:40 [INFO] [stdout] | [INFO] [stdout] 1 | use entity_lib::entity::MasterEntity::{Statement, TableStructure}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `serde_json::json` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:2:5 [INFO] [stdout] | [INFO] [stdout] 2 | use serde_json::json; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AsyncReadExt` and `AsyncWriteExt` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:3:17 [INFO] [stdout] | [INFO] [stdout] 3 | use tokio::io::{AsyncReadExt, AsyncWriteExt}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Create` and `MesterInsert` [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:4:58 [INFO] [stdout] | [INFO] [stdout] 4 | use entity_lib::entity::MasterEntity::{BatchInsertTruth, Create, MasterStreamRead, MesterInsert}; [INFO] [stdout] | ^^^^^^ ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `sql` should have an upper camel case name [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | sql(String), [INFO] [stdout] | ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Sql` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_camel_case_types)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `stream_read` should have an upper camel case name [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | stream_read(MasterStreamRead), [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `batch_insert` should have an upper camel case name [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | batch_insert(BatchInsertTruth), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Decoder` [INFO] [stdout] --> data-lake-client/src/main.rs:6:17 [INFO] [stdout] | [INFO] [stdout] 6 | use snap::raw::{Decoder, Encoder}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `TableStructure` [INFO] [stdout] --> data-lake-client/src/main.rs:10:51 [INFO] [stdout] | [INFO] [stdout] 10 | use entity_lib::entity::MasterEntity::{Statement, TableStructure}; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> data-lake-client/src/main.rs:118:17 [INFO] [stdout] | [INFO] [stdout] 118 | / /** [INFO] [stdout] 119 | | pub table_name: &'a str, [INFO] [stdout] 120 | | pub column: Vec<&'a str>, [INFO] [stdout] 121 | | pub data: Vec>, [INFO] [stdout] 122 | | **/ [INFO] [stdout] | |___________________^ [INFO] [stdout] 123 | let mut column_map = HashMap::::new(); [INFO] [stdout] | ----------------------------------------------------- rustdoc does not generate documentation for statements [INFO] [stdout] | [INFO] [stdout] = help: use `/* */` for a plain comment [INFO] [stdout] = note: `#[warn(unused_doc_comments)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-client/src/controls/stream_read_logic.rs:78:21 [INFO] [stdout] | [INFO] [stdout] 78 | let mut hash_map = &self.hash_map; [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Statement` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:1:40 [INFO] [stdout] | [INFO] [stdout] 1 | use entity_lib::entity::MasterEntity::{Statement, TableStructure}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `serde_json::json` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:2:5 [INFO] [stdout] | [INFO] [stdout] 2 | use serde_json::json; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AsyncReadExt` and `AsyncWriteExt` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:3:17 [INFO] [stdout] | [INFO] [stdout] 3 | use tokio::io::{AsyncReadExt, AsyncWriteExt}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Create` and `MesterInsert` [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:4:58 [INFO] [stdout] | [INFO] [stdout] 4 | use entity_lib::entity::MasterEntity::{BatchInsertTruth, Create, MasterStreamRead, MesterInsert}; [INFO] [stdout] | ^^^^^^ ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `sql` should have an upper camel case name [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | sql(String), [INFO] [stdout] | ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Sql` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_camel_case_types)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `stream_read` should have an upper camel case name [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | stream_read(MasterStreamRead), [INFO] [stdout] | ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variant `batch_insert` should have an upper camel case name [INFO] [stdout] --> data-lake-client/src/entity/mod.rs:15:5 [INFO] [stdout] | [INFO] [stdout] 15 | batch_insert(BatchInsertTruth), [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Decoder` [INFO] [stdout] --> data-lake-client/src/main.rs:6:17 [INFO] [stdout] | [INFO] [stdout] 6 | use snap::raw::{Decoder, Encoder}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `TableStructure` [INFO] [stdout] --> data-lake-client/src/main.rs:10:51 [INFO] [stdout] | [INFO] [stdout] 10 | use entity_lib::entity::MasterEntity::{Statement, TableStructure}; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> data-lake-client/src/main.rs:118:17 [INFO] [stdout] | [INFO] [stdout] 118 | / /** [INFO] [stdout] 119 | | pub table_name: &'a str, [INFO] [stdout] 120 | | pub column: Vec<&'a str>, [INFO] [stdout] 121 | | pub data: Vec>, [INFO] [stdout] 122 | | **/ [INFO] [stdout] | |___________________^ [INFO] [stdout] 123 | let mut column_map = HashMap::::new(); [INFO] [stdout] | ----------------------------------------------------- rustdoc does not generate documentation for statements [INFO] [stdout] | [INFO] [stdout] = help: use `/* */` for a plain comment [INFO] [stdout] = note: `#[warn(unused_doc_comments)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `log::log` [INFO] [stdout] --> slave/src/controls/compress_table.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use log::log; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> slave/src/controls/insert_data.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::SeekFrom` [INFO] [stdout] --> slave/src/controls/insert_data.rs:2:5 [INFO] [stdout] | [INFO] [stdout] 2 | use std::io::SeekFrom; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::LazyLock` [INFO] [stdout] --> slave/src/controls/insert_data.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use std::sync::LazyLock; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::MmapMut` [INFO] [stdout] --> slave/src/controls/insert_data.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use memmap2::MmapMut; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `snap::raw::Encoder` [INFO] [stdout] --> slave/src/controls/insert_data.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use snap::raw::Encoder; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::fs::OpenOptions` [INFO] [stdout] --> slave/src/controls/insert_data.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use tokio::fs::OpenOptions; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AsyncReadExt`, `AsyncSeekExt`, and `AsyncWriteExt` [INFO] [stdout] --> slave/src/controls/insert_data.rs:7:17 [INFO] [stdout] | [INFO] [stdout] 7 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::sync::Mutex` [INFO] [stdout] --> slave/src/controls/insert_data.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | use tokio::sync::Mutex; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `DATA_FILE_EXTENSION`, `INDEX_FILE_EXTENSION`, `LOG_FILE`, and `METADATA_LOG` [INFO] [stdout] --> slave/src/controls/insert_data.rs:9:42 [INFO] [stdout] | [INFO] [stdout] 9 | use entity_lib::entity::const_property::{DATA_FILE_EXTENSION, INDEX_FILE_EXTENSION, LOG_FILE, METADATA_LOG}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::DaqlEntity::DaqlType::COMPRESS_TABLE` [INFO] [stdout] --> slave/src/controls/insert_data.rs:10:5 [INFO] [stdout] | [INFO] [stdout] 10 | use entity_lib::entity::DaqlEntity::DaqlType::COMPRESS_TABLE; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::Error::DataLakeError` [INFO] [stdout] --> slave/src/controls/insert_data.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use entity_lib::entity::Error::DataLakeError; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::MasterEntity::Insert` [INFO] [stdout] --> slave/src/controls/insert_data.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use entity_lib::entity::MasterEntity::Insert; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `DataStructure`, `IndexStruct`, and `SlaveCacheStruct` [INFO] [stdout] --> slave/src/controls/insert_data.rs:13:39 [INFO] [stdout] | [INFO] [stdout] 13 | use entity_lib::entity::SlaveEntity::{DataStructure, IndexStruct, SlaveCacheStruct}; [INFO] [stdout] | ^^^^^^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `DataStructure` [INFO] [stdout] --> slave/src/controls/query_table.rs:2:39 [INFO] [stdout] | [INFO] [stdout] 2 | use entity_lib::entity::SlaveEntity::{DataStructure, QueryMessage}; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::Mmap` [INFO] [stdout] --> slave/src/controls/query_table.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use memmap2::Mmap; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::fmt::format` [INFO] [stdout] --> slave/src/controls/stream_read.rs:11:5 [INFO] [stdout] | [INFO] [stdout] 11 | use std::fmt::format; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::panic::Location` [INFO] [stdout] --> slave/src/controls/stream_read.rs:12:5 [INFO] [stdout] | [INFO] [stdout] 12 | use std::panic::Location; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> slave/src/controls/stream_read.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Instant` [INFO] [stdout] --> slave/src/controls/stream_read.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | use std::time::Instant; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::io::AsyncSeekExt` [INFO] [stdout] --> slave/src/controls/stream_read.rs:16:5 [INFO] [stdout] | [INFO] [stdout] 16 | use tokio::io::AsyncSeekExt; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `table_Key_words` should have a snake case name [INFO] [stdout] --> daql_analysis/src/lib.rs:28:13 [INFO] [stdout] | [INFO] [stdout] 28 | let table_Key_words = sql[7..12].trim(); [INFO] [stdout] | ^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `table_key_words` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_snake_case)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around assigned value [INFO] [stdout] --> slave/src/controls/stream_read.rs:317:24 [INFO] [stdout] | [INFO] [stdout] 317 | left = (mid + 1); [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_parens)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 317 - left = (mid + 1); [INFO] [stdout] 317 + left = mid + 1 ; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around assigned value [INFO] [stdout] --> slave/src/controls/stream_read.rs:319:25 [INFO] [stdout] | [INFO] [stdout] 319 | right = (mid - 1); [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 319 - right = (mid - 1); [INFO] [stdout] 319 + right = mid - 1 ; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary trailing semicolon [INFO] [stdout] --> slave/src/controls/batch_insert.rs:155:85 [INFO] [stdout] | [INFO] [stdout] 155 | let data_file_len = slave_cache_struct.get_data_file().stream_position().await?;; [INFO] [stdout] | ^ help: remove this semicolon [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(redundant_semicolons)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::error::Error` [INFO] [stdout] --> slave/src/controls/max_offset.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::error::Error; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::controls` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::controls; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `SlaveCacheStruct` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:5:119 [INFO] [stdout] | [INFO] [stdout] 5 | ...ncStruct, ReplicasSyncTcpCacheStruct, ReplicaseSyncData, SlaveCacheStruct, SlaveMessage, SyncMessage}; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `col_type_Identification` should have a snake case name [INFO] [stdout] --> daql_analysis/src/analysis/create_daql.rs:17:9 [INFO] [stdout] | [INFO] [stdout] 17 | let col_type_Identification = sql[left_parenthesis_index+1..right_parenthesis_index].trim(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `col_type_identification` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `MmapMut` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:9:21 [INFO] [stdout] | [INFO] [stdout] 9 | use memmap2::{Mmap, MmapMut}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `LazyLock` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:11:22 [INFO] [stdout] | [INFO] [stdout] 11 | use std::sync::{Arc, LazyLock}; [INFO] [stdout] | ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::net::TcpStream` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:14:5 [INFO] [stdout] | [INFO] [stdout] 14 | use tokio::net::TcpStream; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `FILE_CACHE_POOL` [INFO] [stdout] --> slave/src/mechanism/replicas.rs:16:42 [INFO] [stdout] | [INFO] [stdout] 16 | use entity_lib::function::BufferObject::{FILE_CACHE_POOL, SLAVE_REPLICAS_SYNC_TCP_CACHE}; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::ErrorKind` [INFO] [stdout] --> slave/src/main.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use std::io::ErrorKind; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Datelike` and `Timelike` [INFO] [stdout] --> slave/src/main.rs:12:14 [INFO] [stdout] | [INFO] [stdout] 12 | use chrono::{Datelike, Timelike}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `error` [INFO] [stdout] --> slave/src/main.rs:17:11 [INFO] [stdout] | [INFO] [stdout] 17 | use log::{error, info}; [INFO] [stdout] | ^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `Instant` [INFO] [stdout] --> slave/src/main.rs:20:27 [INFO] [stdout] | [INFO] [stdout] 20 | use std::time::{Duration, Instant, SystemTime, UNIX_EPOCH}; [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary parentheses around assigned value [INFO] [stdout] --> slave/src/main.rs:372:61 [INFO] [stdout] | [INFO] [stdout] 372 | ... let bytes_len = (offset_bytes.len() as i32); [INFO] [stdout] | ^ ^ [INFO] [stdout] | [INFO] [stdout] help: remove these parentheses [INFO] [stdout] | [INFO] [stdout] 372 - let bytes_len = (offset_bytes.len() as i32); [INFO] [stdout] 372 + let bytes_len = offset_bytes.len() as i32 ; [INFO] [stdout] | [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/stream_read.rs:174:9 [INFO] [stdout] | [INFO] [stdout] 174 | let mut log_files = entity_lib::function::get_list_filename(&partition_name).await; [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-client/src/controls/stream_read_logic.rs:78:21 [INFO] [stdout] | [INFO] [stdout] 78 | let mut hash_map = &self.hash_map; [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-client/src/controls/stream_read_logic.rs:28:13 [INFO] [stdout] | [INFO] [stdout] 28 | let mut hash_map = HashMap::::new(); [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `bytes` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | bytes: &[u8], [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_bytes` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `bytes_len` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | bytes_len: usize, [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_bytes_len` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `stream` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:9:5 [INFO] [stdout] | [INFO] [stdout] 9 | stream: &mut TcpStream, [INFO] [stdout] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/stream_read.rs:331:9 [INFO] [stdout] | [INFO] [stdout] 331 | let mut end_seek = start_seek + (read_count * INDEX_SIZE); [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unreachable pattern [INFO] [stdout] --> data-lake-client/src/main.rs:183:13 [INFO] [stdout] | [INFO] [stdout] 183 | _ =>{ [INFO] [stdout] | ^ no value can reach this [INFO] [stdout] | [INFO] [stdout] note: multiple earlier patterns match some of the same values [INFO] [stdout] --> data-lake-client/src/main.rs:183:13 [INFO] [stdout] | [INFO] [stdout] 53 | ClientStatement::sql(sql) => { [INFO] [stdout] | ------------------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 96 | ClientStatement::stream_read(stream_read) => { [INFO] [stdout] | ----------------------------------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 113 | ClientStatement::batch_insert(batch_insert) => { [INFO] [stdout] | ------------------------------------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 183 | _ =>{ [INFO] [stdout] | ^ collectively making this unreachable [INFO] [stdout] = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `sql` [INFO] [stdout] --> data-lake-client/src/main.rs:53:34 [INFO] [stdout] | [INFO] [stdout] 53 | ClientStatement::sql(sql) => { [INFO] [stdout] | ^^^ help: if this is intentional, prefix it with an underscore: `_sql` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `StreamRead` is never constructed [INFO] [stdout] --> data-lake-client/src/controls/stream_read_logic.rs:11:8 [INFO] [stdout] | [INFO] [stdout] 11 | struct StreamRead { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_metadata` is never used [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:6:14 [INFO] [stdout] | [INFO] [stdout] 6 | pub async fn get_metadata( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `table_Key_words` should have a snake case name [INFO] [stdout] --> daql_analysis/src/lib.rs:28:13 [INFO] [stdout] | [INFO] [stdout] 28 | let table_Key_words = sql[7..12].trim(); [INFO] [stdout] | ^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `table_key_words` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_snake_case)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `col_type_Identification` should have a snake case name [INFO] [stdout] --> daql_analysis/src/analysis/create_daql.rs:17:9 [INFO] [stdout] | [INFO] [stdout] 17 | let col_type_Identification = sql[left_parenthesis_index+1..right_parenthesis_index].trim(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `col_type_identification` [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Checking master v0.1.0 (/opt/rustwide/workdir/master) [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/batch_insert.rs:246:17 [INFO] [stdout] | [INFO] [stdout] 246 | let mut metadata_file = OpenOptions::new() [INFO] [stdout] | ----^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/batch_insert.rs:252:17 [INFO] [stdout] | [INFO] [stdout] 252 | let mut metadata_mmap = unsafe { MmapMut::map_mut(&metadata_file)? }; [INFO] [stdout] | ----^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/compress_table.rs:50:9 [INFO] [stdout] | [INFO] [stdout] 50 | let mut log_files = get_list_filename(&table_name).await; [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> data-lake-client/src/controls/stream_read_logic.rs:28:13 [INFO] [stdout] | [INFO] [stdout] 28 | let mut hash_map = HashMap::::new(); [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `bytes` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | bytes: &[u8], [INFO] [stdout] | ^^^^^ help: if this is intentional, prefix it with an underscore: `_bytes` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `bytes_len` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:8:5 [INFO] [stdout] | [INFO] [stdout] 8 | bytes_len: usize, [INFO] [stdout] | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_bytes_len` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `stream` [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:9:5 [INFO] [stdout] | [INFO] [stdout] 9 | stream: &mut TcpStream, [INFO] [stdout] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/stream_read.rs:174:9 [INFO] [stdout] | [INFO] [stdout] 174 | let mut log_files = entity_lib::function::get_list_filename(&partition_name).await; [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/mechanism/replicas.rs:152:9 [INFO] [stdout] | [INFO] [stdout] 152 | let mut log_files = entity_lib::function::get_list_filename(&partition_code).await; [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/stream_read.rs:331:9 [INFO] [stdout] | [INFO] [stdout] 331 | let mut end_seek = start_seek + (read_count * INDEX_SIZE); [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unreachable pattern [INFO] [stdout] --> data-lake-client/src/main.rs:183:13 [INFO] [stdout] | [INFO] [stdout] 183 | _ =>{ [INFO] [stdout] | ^ no value can reach this [INFO] [stdout] | [INFO] [stdout] note: multiple earlier patterns match some of the same values [INFO] [stdout] --> data-lake-client/src/main.rs:183:13 [INFO] [stdout] | [INFO] [stdout] 53 | ClientStatement::sql(sql) => { [INFO] [stdout] | ------------------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 96 | ClientStatement::stream_read(stream_read) => { [INFO] [stdout] | ----------------------------------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 113 | ClientStatement::batch_insert(batch_insert) => { [INFO] [stdout] | ------------------------------------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 183 | _ =>{ [INFO] [stdout] | ^ collectively making this unreachable [INFO] [stdout] = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::MasterEntity::TableStructure` [INFO] [stdout] --> master/src/controls/metadata.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use entity_lib::entity::MasterEntity::TableStructure; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::Mmap` [INFO] [stdout] --> master/src/controls/metadata.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use memmap2::Mmap; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::path::Path` [INFO] [stdout] --> master/src/controls/metadata.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use std::path::Path; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::fs::OpenOptions` [INFO] [stdout] --> master/src/controls/metadata.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use tokio::fs::OpenOptions; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::function::MASTER_CONFIG` [INFO] [stdout] --> master/src/controls/metadata.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | use entity_lib::function::MASTER_CONFIG; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> master/src/controls/query.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `SlaveMessage` [INFO] [stdout] --> master/src/controls/query.rs:3:53 [INFO] [stdout] | [INFO] [stdout] 3 | use entity_lib::entity::SlaveEntity::{QueryMessage, SlaveMessage}; [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> master/src/controls/query.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AsyncReadExt` and `AsyncWriteExt` [INFO] [stdout] --> master/src/controls/query.rs:5:17 [INFO] [stdout] | [INFO] [stdout] 5 | use tokio::io::{AsyncReadExt, AsyncWriteExt}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::net::TcpStream` [INFO] [stdout] --> master/src/controls/query.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use tokio::net::TcpStream; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Info` and `PartitionInfo` [INFO] [stdout] --> master/src/controls/query.rs:7:40 [INFO] [stdout] | [INFO] [stdout] 7 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo}; [INFO] [stdout] | ^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::controls::max_offset::partition_max_offset` [INFO] [stdout] --> master/src/mechanism/replicas.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::controls::max_offset::partition_max_offset; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `info` [INFO] [stdout] --> master/src/mechanism/replicas.rs:12:18 [INFO] [stdout] | [INFO] [stdout] 12 | use log::{error, info}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::Mmap` [INFO] [stdout] --> master/src/mechanism/replicas.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | use memmap2::Mmap; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `JoinError` [INFO] [stdout] --> master/src/mechanism/replicas.rs:19:19 [INFO] [stdout] | [INFO] [stdout] 19 | use tokio::task::{JoinError, JoinHandle}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Datelike` and `Timelike` [INFO] [stdout] --> master/src/main.rs:12:14 [INFO] [stdout] | [INFO] [stdout] 12 | use chrono::{Datelike, Timelike}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::any::Any` [INFO] [stdout] --> master/src/main.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | use std::any::Any; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Instant` [INFO] [stdout] --> master/src/main.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | use std::time::Instant; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> master/src/main.rs:315:29 [INFO] [stdout] | [INFO] [stdout] 315 | / ... /** [INFO] [stdout] 316 | | ... 操作 危险场景 规避方案 [INFO] [stdout] 317 | | ... iter() | 持有迭代器时尝试写操作（同线程） | 避免在迭代中修改当前 map [INFO] [stdout] 318 | | ... get_mut() | 持有任意引用时调用 | 缩短引用生命周期，尽快释放锁 [INFO] [stdout] ... | [INFO] [stdout] 321 | | ... **/ [INFO] [stdout] | |_____________________________________________________^ [INFO] [stdout] 322 | / ... { [INFO] [stdout] 323 | | ... let mut key_vec = Vec::::new(); [INFO] [stdout] 324 | | ... let insert_tcpstream_cache_pool = [INFO] [stdout] 325 | | ... Arc::clone(&INSERT_TCPSTREAM_CACHE_POOL); [INFO] [stdout] ... | [INFO] [stdout] 336 | | ... }); [INFO] [stdout] 337 | | ... } [INFO] [stdout] | |_______________________- rustdoc does not generate documentation for expressions [INFO] [stdout] | [INFO] [stdout] = help: use `/* */` for a plain comment [INFO] [stdout] = note: `#[warn(unused_doc_comments)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::Write` [INFO] [stdout] --> slave/src/controls/batch_insert.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | use std::io::Write; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::entity::MasterEntity::TableStructure` [INFO] [stdout] --> master/src/controls/metadata.rs:3:5 [INFO] [stdout] | [INFO] [stdout] 3 | use entity_lib::entity::MasterEntity::TableStructure; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::Mmap` [INFO] [stdout] --> master/src/controls/metadata.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use memmap2::Mmap; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::path::Path` [INFO] [stdout] --> master/src/controls/metadata.rs:5:5 [INFO] [stdout] | [INFO] [stdout] 5 | use std::path::Path; [INFO] [stdout] | ^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::fs::OpenOptions` [INFO] [stdout] --> master/src/controls/metadata.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use tokio::fs::OpenOptions; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `entity_lib::function::MASTER_CONFIG` [INFO] [stdout] --> master/src/controls/metadata.rs:7:5 [INFO] [stdout] | [INFO] [stdout] 7 | use entity_lib::function::MASTER_CONFIG; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::collections::HashMap` [INFO] [stdout] --> master/src/controls/query.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use std::collections::HashMap; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `SlaveMessage` [INFO] [stdout] --> master/src/controls/query.rs:3:53 [INFO] [stdout] | [INFO] [stdout] 3 | use entity_lib::entity::SlaveEntity::{QueryMessage, SlaveMessage}; [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::sync::Arc` [INFO] [stdout] --> master/src/controls/query.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use std::sync::Arc; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `AsyncReadExt` and `AsyncWriteExt` [INFO] [stdout] --> master/src/controls/query.rs:5:17 [INFO] [stdout] | [INFO] [stdout] 5 | use tokio::io::{AsyncReadExt, AsyncWriteExt}; [INFO] [stdout] | ^^^^^^^^^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `tokio::net::TcpStream` [INFO] [stdout] --> master/src/controls/query.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use tokio::net::TcpStream; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Info` and `PartitionInfo` [INFO] [stdout] --> master/src/controls/query.rs:7:40 [INFO] [stdout] | [INFO] [stdout] 7 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo}; [INFO] [stdout] | ^^^^ ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `crate::controls::max_offset::partition_max_offset` [INFO] [stdout] --> master/src/mechanism/replicas.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use crate::controls::max_offset::partition_max_offset; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `info` [INFO] [stdout] --> master/src/mechanism/replicas.rs:12:18 [INFO] [stdout] | [INFO] [stdout] 12 | use log::{error, info}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `memmap2::Mmap` [INFO] [stdout] --> master/src/mechanism/replicas.rs:13:5 [INFO] [stdout] | [INFO] [stdout] 13 | use memmap2::Mmap; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `JoinError` [INFO] [stdout] --> master/src/mechanism/replicas.rs:19:19 [INFO] [stdout] | [INFO] [stdout] 19 | use tokio::task::{JoinError, JoinHandle}; [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused imports: `Datelike` and `Timelike` [INFO] [stdout] --> master/src/main.rs:12:14 [INFO] [stdout] | [INFO] [stdout] 12 | use chrono::{Datelike, Timelike}; [INFO] [stdout] | ^^^^^^^^ ^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::any::Any` [INFO] [stdout] --> master/src/main.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | use std::any::Any; [INFO] [stdout] | ^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::time::Instant` [INFO] [stdout] --> master/src/main.rs:19:5 [INFO] [stdout] | [INFO] [stdout] 19 | use std::time::Instant; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused doc comment [INFO] [stdout] --> master/src/main.rs:315:29 [INFO] [stdout] | [INFO] [stdout] 315 | / ... /** [INFO] [stdout] 316 | | ... 操作 危险场景 规避方案 [INFO] [stdout] 317 | | ... iter() | 持有迭代器时尝试写操作（同线程） | 避免在迭代中修改当前 map [INFO] [stdout] 318 | | ... get_mut() | 持有任意引用时调用 | 缩短引用生命周期，尽快释放锁 [INFO] [stdout] ... | [INFO] [stdout] 321 | | ... **/ [INFO] [stdout] | |_____________________________________________________^ [INFO] [stdout] 322 | / ... { [INFO] [stdout] 323 | | ... let mut key_vec = Vec::::new(); [INFO] [stdout] 324 | | ... let insert_tcpstream_cache_pool = [INFO] [stdout] 325 | | ... Arc::clone(&INSERT_TCPSTREAM_CACHE_POOL); [INFO] [stdout] ... | [INFO] [stdout] 336 | | ... }); [INFO] [stdout] 337 | | ... } [INFO] [stdout] | |_______________________- rustdoc does not generate documentation for expressions [INFO] [stdout] | [INFO] [stdout] = help: use `/* */` for a plain comment [INFO] [stdout] = note: `#[warn(unused_doc_comments)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `sql` [INFO] [stdout] --> data-lake-client/src/main.rs:53:34 [INFO] [stdout] | [INFO] [stdout] 53 | ClientStatement::sql(sql) => { [INFO] [stdout] | ^^^ help: if this is intentional, prefix it with an underscore: `_sql` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/batch_insert.rs:246:17 [INFO] [stdout] | [INFO] [stdout] 246 | let mut metadata_file = OpenOptions::new() [INFO] [stdout] | ----^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/controls/batch_insert.rs:252:17 [INFO] [stdout] | [INFO] [stdout] 252 | let mut metadata_mmap = unsafe { MmapMut::map_mut(&metadata_file)? }; [INFO] [stdout] | ----^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `querymessage` [INFO] [stdout] --> slave/src/controls/query_table.rs:7:20 [INFO] [stdout] | [INFO] [stdout] 7 | pub async fn query(querymessage: QueryMessage, uuid:&String) -> Result>>, DataLakeError> { [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_querymessage` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `uuid` [INFO] [stdout] --> slave/src/controls/query_table.rs:7:48 [INFO] [stdout] | [INFO] [stdout] 7 | pub async fn query(querymessage: QueryMessage, uuid:&String) -> Result>>, DataLakeError> { [INFO] [stdout] | ^^^^ help: if this is intentional, prefix it with an underscore: `_uuid` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: struct `StreamRead` is never constructed [INFO] [stdout] --> data-lake-client/src/controls/stream_read_logic.rs:11:8 [INFO] [stdout] | [INFO] [stdout] 11 | struct StreamRead { [INFO] [stdout] | ^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `get_metadata` is never used [INFO] [stdout] --> data-lake-client/src/controls/metadata_logic.rs:6:14 [INFO] [stdout] | [INFO] [stdout] 6 | pub async fn get_metadata( [INFO] [stdout] | ^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unreachable pattern [INFO] [stdout] --> slave/src/controls/batch_insert.rs:362:9 [INFO] [stdout] | [INFO] [stdout] 362 | _ => { [INFO] [stdout] | ^ no value can reach this [INFO] [stdout] | [INFO] [stdout] note: multiple earlier patterns match some of the same values [INFO] [stdout] --> slave/src/controls/batch_insert.rs:362:9 [INFO] [stdout] | [INFO] [stdout] 327 | DataType::string => { [INFO] [stdout] | ---------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 330 | DataType::int => { [INFO] [stdout] | ------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 338 | DataType::float => { [INFO] [stdout] | --------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 346 | DataType::boolean => { [INFO] [stdout] | ----------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 362 | _ => { [INFO] [stdout] | ^ ...and 1 other patterns collectively make this unreachable [INFO] [stdout] = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> slave/src/mechanism/replicas.rs:152:9 [INFO] [stdout] | [INFO] [stdout] 152 | let mut log_files = entity_lib::function::get_list_filename(&partition_code).await; [INFO] [stdout] | ----^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary `unsafe` block [INFO] [stdout] --> slave/src/main.rs:67:9 [INFO] [stdout] | [INFO] [stdout] 67 | unsafe { [INFO] [stdout] | ^^^^^^ unnecessary `unsafe` block [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_unsafe)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `std::io::Write` [INFO] [stdout] --> slave/src/controls/batch_insert.rs:17:5 [INFO] [stdout] | [INFO] [stdout] 17 | use std::io::Write; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> master/src/controls/batch_insert.rs:51:17 [INFO] [stdout] | [INFO] [stdout] 51 | let mut table_structure = match get_table_structure(&table_name).await { [INFO] [stdout] | ----^^^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `insert` [INFO] [stdout] --> slave/src/main.rs:207:54 [INFO] [stdout] | [INFO] [stdout] 207 | ... SlaveMessage::insert(insert) => { [INFO] [stdout] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_insert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `querymessage` [INFO] [stdout] --> slave/src/controls/query_table.rs:7:20 [INFO] [stdout] | [INFO] [stdout] 7 | pub async fn query(querymessage: QueryMessage, uuid:&String) -> Result>>, DataLakeError> { [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_querymessage` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> master/src/controls/batch_insert.rs:51:17 [INFO] [stdout] | [INFO] [stdout] 51 | let mut table_structure = match get_table_structure(&table_name).await { [INFO] [stdout] | ----^^^^^^^^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_mut)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `uuid` [INFO] [stdout] --> slave/src/controls/query_table.rs:7:48 [INFO] [stdout] | [INFO] [stdout] 7 | pub async fn query(querymessage: QueryMessage, uuid:&String) -> Result>>, DataLakeError> { [INFO] [stdout] | ^^^^ help: if this is intentional, prefix it with an underscore: `_uuid` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 0 that must be used [INFO] [stdout] --> slave/src/main.rs:85:5 [INFO] [stdout] | [INFO] [stdout] 85 | tokio::join!(slave, regular_cleaning); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 1 that must be used [INFO] [stdout] --> slave/src/main.rs:85:5 [INFO] [stdout] | [INFO] [stdout] 85 | tokio::join!(slave, regular_cleaning); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `tmpfile_offsetCode` should have a snake case name [INFO] [stdout] --> slave/src/controls/compress_table.rs:102:13 [INFO] [stdout] | [INFO] [stdout] 102 | let mut tmpfile_offsetCode = HashMap::::new(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `tmpfile_offset_code` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_snake_case)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> slave/src/controls/stream_read.rs:85:46 [INFO] [stdout] | [INFO] [stdout] 85 | ... unsafe { Box::from_raw(box_leak) }; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 85 | unsafe { let _ = Box::from_raw(box_leak); }; [INFO] [stdout] | +++++++ + [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `serialize_vec_dataStructure` should have a snake case name [INFO] [stdout] --> slave/src/controls/stream_read.rs:123:4 [INFO] [stdout] | [INFO] [stdout] 123 | fn serialize_vec_dataStructure<'a>(vec: Vec>) -> Result, DataLakeError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `serialize_vec_data_structure` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `Index_struct` should have a snake case name [INFO] [stdout] --> slave/src/controls/stream_read.rs:257:13 [INFO] [stdout] | [INFO] [stdout] 257 | let Index_struct = bincode::deserialize::(index_bytes)?; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `index_struct` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `end_Index_struct` should have a snake case name [INFO] [stdout] --> slave/src/mechanism/replicas.rs:119:13 [INFO] [stdout] | [INFO] [stdout] 119 | let end_Index_struct = bincode::deserialize::(return_end_offset)?; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `end_index_struct` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `Leader_replicas_sync` should have a snake case name [INFO] [stdout] --> slave/src/mechanism/replicas.rs:144:14 [INFO] [stdout] | [INFO] [stdout] 144 | pub async fn Leader_replicas_sync( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `leader_replicas_sync` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unreachable pattern [INFO] [stdout] --> slave/src/controls/batch_insert.rs:362:9 [INFO] [stdout] | [INFO] [stdout] 362 | _ => { [INFO] [stdout] | ^ no value can reach this [INFO] [stdout] | [INFO] [stdout] note: multiple earlier patterns match some of the same values [INFO] [stdout] --> slave/src/controls/batch_insert.rs:362:9 [INFO] [stdout] | [INFO] [stdout] 327 | DataType::string => { [INFO] [stdout] | ---------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 330 | DataType::int => { [INFO] [stdout] | ------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 338 | DataType::float => { [INFO] [stdout] | --------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 346 | DataType::boolean => { [INFO] [stdout] | ----------------- matches some of the same values [INFO] [stdout] ... [INFO] [stdout] 362 | _ => { [INFO] [stdout] | ^ ...and 1 other patterns collectively make this unreachable [INFO] [stdout] = note: `#[warn(unreachable_patterns)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary `unsafe` block [INFO] [stdout] --> slave/src/main.rs:67:9 [INFO] [stdout] | [INFO] [stdout] 67 | unsafe { [INFO] [stdout] | ^^^^^^ unnecessary `unsafe` block [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_unsafe)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `rayon::prelude` [INFO] [stdout] --> master/src/controls/batch_insert.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use rayon::prelude::*; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `insert` [INFO] [stdout] --> slave/src/main.rs:207:54 [INFO] [stdout] | [INFO] [stdout] 207 | ... SlaveMessage::insert(insert) => { [INFO] [stdout] | ^^^^^^ help: if this is intentional, prefix it with an underscore: `_insert` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `query_message` [INFO] [stdout] --> master/src/controls/query.rs:9:25 [INFO] [stdout] | [INFO] [stdout] 9 | pub async fn query_daql(query_message: QueryMessage) -> Result>, DataLakeError> { [INFO] [stdout] | ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_query_message` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 0 that must be used [INFO] [stdout] --> slave/src/main.rs:85:5 [INFO] [stdout] | [INFO] [stdout] 85 | tokio::join!(slave, regular_cleaning); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 1 that must be used [INFO] [stdout] --> slave/src/main.rs:85:5 [INFO] [stdout] | [INFO] [stdout] 85 | tokio::join!(slave, regular_cleaning); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `tmpfile_offsetCode` should have a snake case name [INFO] [stdout] --> slave/src/controls/compress_table.rs:102:13 [INFO] [stdout] | [INFO] [stdout] 102 | let mut tmpfile_offsetCode = HashMap::::new(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `tmpfile_offset_code` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(non_snake_case)]` (part of `#[warn(nonstandard_style)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> slave/src/controls/stream_read.rs:85:46 [INFO] [stdout] | [INFO] [stdout] 85 | ... unsafe { Box::from_raw(box_leak) }; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 85 | unsafe { let _ = Box::from_raw(box_leak); }; [INFO] [stdout] | +++++++ + [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `serialize_vec_dataStructure` should have a snake case name [INFO] [stdout] --> slave/src/controls/stream_read.rs:123:4 [INFO] [stdout] | [INFO] [stdout] 123 | fn serialize_vec_dataStructure<'a>(vec: Vec>) -> Result, DataLakeError> { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `serialize_vec_data_structure` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `Index_struct` should have a snake case name [INFO] [stdout] --> slave/src/controls/stream_read.rs:257:13 [INFO] [stdout] | [INFO] [stdout] 257 | let Index_struct = bincode::deserialize::(index_bytes)?; [INFO] [stdout] | ^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `index_struct` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable `end_Index_struct` should have a snake case name [INFO] [stdout] --> slave/src/mechanism/replicas.rs:119:13 [INFO] [stdout] | [INFO] [stdout] 119 | let end_Index_struct = bincode::deserialize::(return_end_offset)?; [INFO] [stdout] | ^^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `end_index_struct` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: function `Leader_replicas_sync` should have a snake case name [INFO] [stdout] --> slave/src/mechanism/replicas.rs:144:14 [INFO] [stdout] | [INFO] [stdout] 144 | pub async fn Leader_replicas_sync( [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `leader_replicas_sync` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `rayon::prelude` [INFO] [stdout] --> master/src/controls/batch_insert.rs:4:5 [INFO] [stdout] | [INFO] [stdout] 4 | use rayon::prelude::*; [INFO] [stdout] | ^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `query_message` [INFO] [stdout] --> master/src/controls/query.rs:9:25 [INFO] [stdout] | [INFO] [stdout] 9 | pub async fn query_daql(query_message: QueryMessage) -> Result>, DataLakeError> { [INFO] [stdout] | ^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_query_message` [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_variables)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `x3` [INFO] [stdout] --> master/src/mechanism/replicas.rs:261:27 [INFO] [stdout] | [INFO] [stdout] 261 | .map(|x3| 1) [INFO] [stdout] | ^^ help: if this is intentional, prefix it with an underscore: `_x3` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary `unsafe` block [INFO] [stdout] --> master/src/main.rs:60:9 [INFO] [stdout] | [INFO] [stdout] 60 | unsafe { [INFO] [stdout] | ^^^^^^ unnecessary `unsafe` block [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_unsafe)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `x3` [INFO] [stdout] --> master/src/mechanism/replicas.rs:261:27 [INFO] [stdout] | [INFO] [stdout] 261 | .map(|x3| 1) [INFO] [stdout] | ^^ help: if this is intentional, prefix it with an underscore: `_x3` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> master/src/main.rs:262:44 [INFO] [stdout] | [INFO] [stdout] 262 | ... Ok(mut vec_data) => { [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `querymessage` [INFO] [stdout] --> master/src/main.rs:122:64 [INFO] [stdout] | [INFO] [stdout] 122 | ... DaqlType::SELECT_TABLE(querymessage) => { [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_querymessage` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `e` [INFO] [stdout] --> master/src/main.rs:312:29 [INFO] [stdout] | [INFO] [stdout] 312 | Err(e) => { [INFO] [stdout] | ^ help: if this is intentional, prefix it with an underscore: `_e` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unnecessary `unsafe` block [INFO] [stdout] --> master/src/main.rs:60:9 [INFO] [stdout] | [INFO] [stdout] 60 | unsafe { [INFO] [stdout] | ^^^^^^ unnecessary `unsafe` block [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_unsafe)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 0 that must be used [INFO] [stdout] --> master/src/main.rs:71:5 [INFO] [stdout] | [INFO] [stdout] 71 | tokio::join!(master_main, replicas_sync); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 1 that must be used [INFO] [stdout] --> master/src/main.rs:71:5 [INFO] [stdout] | [INFO] [stdout] 71 | tokio::join!(master_main, replicas_sync); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:43:21 [INFO] [stdout] | [INFO] [stdout] 43 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 43 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:44:21 [INFO] [stdout] | [INFO] [stdout] 44 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 44 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:55:25 [INFO] [stdout] | [INFO] [stdout] 55 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 55 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:56:25 [INFO] [stdout] | [INFO] [stdout] 56 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 56 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:71:25 [INFO] [stdout] | [INFO] [stdout] 71 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 71 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:72:25 [INFO] [stdout] | [INFO] [stdout] 72 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 72 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:184:33 [INFO] [stdout] | [INFO] [stdout] 184 | ... Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 184 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:185:33 [INFO] [stdout] | [INFO] [stdout] 185 | ... Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 185 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:193:29 [INFO] [stdout] | [INFO] [stdout] 193 | ... Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 193 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:194:29 [INFO] [stdout] | [INFO] [stdout] 194 | ... Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 194 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:201:17 [INFO] [stdout] | [INFO] [stdout] 201 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 201 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:202:17 [INFO] [stdout] | [INFO] [stdout] 202 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 202 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:209:17 [INFO] [stdout] | [INFO] [stdout] 209 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 209 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: variable does not need to be mutable [INFO] [stdout] --> master/src/main.rs:262:44 [INFO] [stdout] | [INFO] [stdout] 262 | ... Ok(mut vec_data) => { [INFO] [stdout] | ----^^^^^^^^ [INFO] [stdout] | | [INFO] [stdout] | help: remove this `mut` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `querymessage` [INFO] [stdout] --> master/src/main.rs:122:64 [INFO] [stdout] | [INFO] [stdout] 122 | ... DaqlType::SELECT_TABLE(querymessage) => { [INFO] [stdout] | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_querymessage` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused variable: `e` [INFO] [stdout] --> master/src/main.rs:312:29 [INFO] [stdout] | [INFO] [stdout] 312 | Err(e) => { [INFO] [stdout] | ^ help: if this is intentional, prefix it with an underscore: `_e` [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 0 that must be used [INFO] [stdout] --> master/src/main.rs:71:5 [INFO] [stdout] | [INFO] [stdout] 71 | tokio::join!(master_main, replicas_sync); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] = note: `#[warn(unused_must_use)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused `Result` in tuple element 1 that must be used [INFO] [stdout] --> master/src/main.rs:71:5 [INFO] [stdout] | [INFO] [stdout] 71 | tokio::join!(master_main, replicas_sync); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: this `Result` may be an `Err` variant, which should be handled [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:43:21 [INFO] [stdout] | [INFO] [stdout] 43 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 43 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:44:21 [INFO] [stdout] | [INFO] [stdout] 44 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 44 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:55:25 [INFO] [stdout] | [INFO] [stdout] 55 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 55 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:56:25 [INFO] [stdout] | [INFO] [stdout] 56 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 56 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:71:25 [INFO] [stdout] | [INFO] [stdout] 71 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 71 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:72:25 [INFO] [stdout] | [INFO] [stdout] 72 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 72 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:184:33 [INFO] [stdout] | [INFO] [stdout] 184 | ... Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 184 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:185:33 [INFO] [stdout] | [INFO] [stdout] 185 | ... Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 185 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:193:29 [INFO] [stdout] | [INFO] [stdout] 193 | ... Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 193 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:194:29 [INFO] [stdout] | [INFO] [stdout] 194 | ... Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 194 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:201:17 [INFO] [stdout] | [INFO] [stdout] 201 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 201 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:202:17 [INFO] [stdout] | [INFO] [stdout] 202 | Box::from_raw(batch_data_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 202 | let _ = Box::from_raw(batch_data_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused return value of `Box::::from_raw` that must be used [INFO] [stdout] --> master/src/controls/batch_insert.rs:209:17 [INFO] [stdout] | [INFO] [stdout] 209 | Box::from_raw(message_leak); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: call `drop(Box::from_raw(ptr))` if you intend to drop the `Box` [INFO] [stdout] help: use `let _ = ...` to ignore the resulting value [INFO] [stdout] | [INFO] [stdout] 209 | let _ = Box::from_raw(message_leak); [INFO] [stdout] | +++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 18.19s [INFO] running `Command { std: "docker" "inspect" "5344ca3a06eb5ecf106b35803ae4040ac203aba1796c911372c52a185ef80a6a", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "5344ca3a06eb5ecf106b35803ae4040ac203aba1796c911372c52a185ef80a6a", kill_on_drop: false }` [INFO] [stdout] 5344ca3a06eb5ecf106b35803ae4040ac203aba1796c911372c52a185ef80a6a