[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] b94722c7abd3ea6008c32c9335a0558102316abe
[INFO] testing shenxushenxu/data-lake against try#8de4c7234dd9b97c9d76b58671343fdbbc9a433e+target=x86_64-unknown-linux-musl for musl_upgrade_1_2_5_with_libc_patch_0
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fshenxushenxu%2Fdata-lake" "/workspace/builds/worker-2-tc1/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-2-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-2-tc1/source/Cargo.toml
[INFO] validating manifest of git repo https://github.com/shenxushenxu/data-lake on toolchain 8de4c7234dd9b97c9d76b58671343fdbbc9a433e
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+8de4c7234dd9b97c9d76b58671343fdbbc9a433e" "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" "+8de4c7234dd9b97c9d76b58671343fdbbc9a433e" "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] 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]     Blocking waiting for file lock on package cache
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded uuid v1.14.0
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:90999bfc7ae267e83380e433d8e61a7c072ca6729e92edbae886d3423b3a6f4c" "/opt/rustwide/cargo-home/bin/cargo" "+8de4c7234dd9b97c9d76b58671343fdbbc9a433e" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 1fb81fa018b3bb26b9a5303434ee94ebfcfa94f4a3d07a3918a1319de0ed3d02
[INFO] running `Command { std: "docker" "start" "-a" "1fb81fa018b3bb26b9a5303434ee94ebfcfa94f4a3d07a3918a1319de0ed3d02", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "1fb81fa018b3bb26b9a5303434ee94ebfcfa94f4a3d07a3918a1319de0ed3d02", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "1fb81fa018b3bb26b9a5303434ee94ebfcfa94f4a3d07a3918a1319de0ed3d02", kill_on_drop: false }`
[INFO] [stdout] 1fb81fa018b3bb26b9a5303434ee94ebfcfa94f4a3d07a3918a1319de0ed3d02
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:90999bfc7ae267e83380e433d8e61a7c072ca6729e92edbae886d3423b3a6f4c" "/opt/rustwide/cargo-home/bin/cargo" "+8de4c7234dd9b97c9d76b58671343fdbbc9a433e" "build" "--frozen" "--message-format=json" "--target" "x86_64-unknown-linux-musl", kill_on_drop: false }`
[INFO] [stdout] 02153124d263911211df4bd09a82f961187877cf2d42fb5a2b127287014d68bc
[INFO] running `Command { std: "docker" "start" "-a" "02153124d263911211df4bd09a82f961187877cf2d42fb5a2b127287014d68bc", 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] 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.169
[INFO] [stderr]    Compiling proc-macro2 v1.0.93
[INFO] [stderr]    Compiling unicode-ident v1.0.16
[INFO] [stderr]    Compiling memchr v2.7.4
[INFO] [stderr]    Compiling getrandom v0.3.1
[INFO] [stderr]    Compiling zerocopy v0.8.26
[INFO] [stderr]    Compiling serde v1.0.219
[INFO] [stderr]    Compiling smallvec v1.14.0
[INFO] [stderr]    Compiling snap v1.1.1
[INFO] [stderr]    Compiling serde_json v1.0.140
[INFO] [stderr]    Compiling pin-project-lite v0.2.16
[INFO] [stderr]    Compiling bytes v1.10.0
[INFO] [stderr]    Compiling ryu v1.0.19
[INFO] [stderr]    Compiling itoa v1.0.14
[INFO] [stderr]    Compiling regex-syntax v0.8.5
[INFO] [stderr]    Compiling utf8parse v0.2.2
[INFO] [stderr]    Compiling anstyle-parse v0.2.6
[INFO] [stderr]    Compiling anstyle v1.0.10
[INFO] [stderr]    Compiling anstyle-query v1.1.2
[INFO] [stderr]    Compiling colorchoice v1.0.3
[INFO] [stderr]    Compiling is_terminal_polyfill v1.70.1
[INFO] [stderr]    Compiling log v0.4.26
[INFO] [stderr]    Compiling humantime v2.1.0
[INFO] [stderr]    Compiling anstream v0.6.18
[INFO] [stderr]    Compiling aho-corasick v1.1.3
[INFO] [stderr]    Compiling quote v1.0.38
[INFO] [stderr]    Compiling syn v2.0.98
[INFO] [stderr]    Compiling parking_lot_core v0.9.10
[INFO] [stderr]    Compiling mio v1.0.3
[INFO] [stderr]    Compiling signal-hook-registry v1.4.2
[INFO] [stderr]    Compiling socket2 v0.5.8
[INFO] [stderr]    Compiling memmap2 v0.9.5
[INFO] [stderr]    Compiling rand_core v0.9.3
[INFO] [stderr]    Compiling uuid v1.14.0
[INFO] [stderr]    Compiling regex-automata v0.4.9
[INFO] [stderr]    Compiling parking_lot v0.12.3
[INFO] [stderr]    Compiling ppv-lite86 v0.2.21
[INFO] [stderr]    Compiling rand_chacha v0.9.0
[INFO] [stderr]    Compiling rand v0.9.1
[INFO] [stderr]    Compiling regex v1.11.1
[INFO] [stderr]    Compiling env_filter v0.1.3
[INFO] [stderr]    Compiling serde_derive v1.0.219
[INFO] [stderr]    Compiling tokio-macros v2.5.0
[INFO] [stderr]    Compiling env_logger v0.11.6
[INFO] [stderr]    Compiling tokio v1.45.1
[INFO] [stderr]    Compiling bincode v1.3.3
[INFO] [stderr]    Compiling entity_lib v0.1.0 (/opt/rustwide/workdir/entity_lib)
[INFO] [stdout] warning: variant `string` should have an upper camel case name
[INFO] [stdout]  --> entity_lib/src/entity/MasterEntity.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 |     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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `int` should have an upper camel case name
[INFO] [stdout]  --> entity_lib/src/entity/MasterEntity.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 |     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]  --> entity_lib/src/entity/MasterEntity.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 |     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]  --> entity_lib/src/entity/MasterEntity.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 |     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]   --> entity_lib/src/entity/MasterEntity.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 |     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]   --> entity_lib/src/entity/MasterEntity.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 |     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]   --> entity_lib/src/entity/MasterEntity.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 |     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]   --> entity_lib/src/entity/MasterEntity.rs:98:5
[INFO] [stdout]    |
[INFO] [stdout] 98 |     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]   --> entity_lib/src/entity/MasterEntity.rs:99:5
[INFO] [stdout]    |
[INFO] [stdout] 99 |     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]    --> entity_lib/src/entity/MasterEntity.rs:100:5
[INFO] [stdout]     |
[INFO] [stdout] 100 |     batch_insert(BatchInsert)
[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]    --> entity_lib/src/entity/MasterEntity.rs:157:5
[INFO] [stdout]     |
[INFO] [stdout] 157 |     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]    --> entity_lib/src/entity/MasterEntity.rs:158:5
[INFO] [stdout]     |
[INFO] [stdout] 158 |     column(Vec<String>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:159:5
[INFO] [stdout]     |
[INFO] [stdout] 159 |     term(HashMap<String, serde_json::Value>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:160:5
[INFO] [stdout]     |
[INFO] [stdout] 160 |     gt(HashMap<String, serde_json::Value>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:161:5
[INFO] [stdout]     |
[INFO] [stdout] 161 |     lt(HashMap<String, serde_json::Value>),
[INFO] [stdout]     |     ^^ help: convert the identifier to upper camel case: `Lt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `QueryItem`
[INFO] [stdout]  --> entity_lib/src/entity/SlaveEntity.rs:4:43
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::entity::MasterEntity::{Insert, QueryItem, SlaveInsert};
[INFO] [stdout]   |                                           ^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `create` should have an upper camel case name
[INFO] [stdout]   --> entity_lib/src/entity/SlaveEntity.rs:29:5
[INFO] [stdout]    |
[INFO] [stdout] 29 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:30:5
[INFO] [stdout]    |
[INFO] [stdout] 30 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:31:5
[INFO] [stdout]    |
[INFO] [stdout] 31 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:32:5
[INFO] [stdout]    |
[INFO] [stdout] 32 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:33:5
[INFO] [stdout]    |
[INFO] [stdout] 33 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:34:5
[INFO] [stdout]    |
[INFO] [stdout] 34 |     batch_insert(SlaveInsert),
[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]   --> entity_lib/src/entity/SlaveEntity.rs:35:5
[INFO] [stdout]    |
[INFO] [stdout] 35 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:36:5
[INFO] [stdout]    |
[INFO] [stdout] 36 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:37:5
[INFO] [stdout]    |
[INFO] [stdout] 37 |     leader_replicas_sync(SyncMessage),
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `LeaderReplicasSync`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `CREATE_TABLE` should have an upper camel case name
[INFO] [stdout]  --> entity_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]  --> entity_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]  --> entity_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]   --> entity_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 `SHOW_TABLE` should have an upper camel case name
[INFO] [stdout]   --> entity_lib/src/entity/DaqlEntity.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     SHOW_TABLE(String),
[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]   --> entity_lib/src/entity/DaqlEntity.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 |     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]   --> entity_lib/src/entity/DaqlEntity.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     DROP_TABLE(String),
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Deserialize` and `Serialize`
[INFO] [stdout]  --> entity_lib/src/entity/mod.rs:7:13
[INFO] [stdout]   |
[INFO] [stdout] 7 | use serde::{Deserialize, Serialize};
[INFO] [stdout]   |             ^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::entity::MasterEntity::Statement`
[INFO] [stdout]  --> entity_lib/src/entity/mod.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::entity::MasterEntity::Statement;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `MasterEntity` should have a snake case name
[INFO] [stdout]  --> entity_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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `SlaveEntity` should have a snake case name
[INFO] [stdout]  --> entity_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]  --> entity_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]  --> entity_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] [stderr]    Compiling public_function v0.1.0 (/opt/rustwide/workdir/public_function)
[INFO] [stdout] warning: unused import: `SlaveConfig`
[INFO] [stdout]  --> public_function/src/read_function.rs:1:13
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::{SlaveConfig, SLAVE_CONFIG};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `uuid::Uuid`
[INFO] [stdout]   --> public_function/src/read_function.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use uuid::Uuid;
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::iter::Map`
[INFO] [stdout]  --> public_function/src/lib.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use std::iter::Map;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::net::ToSocketAddrs`
[INFO] [stdout]  --> public_function/src/lib.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use std::net::ToSocketAddrs;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> public_function/src/lib.rs:49:13
[INFO] [stdout]    |
[INFO] [stdout] 49 |         let mut data_path_index = self.data_path_index;
[INFO] [stdout]    |             ----^^^^^^^^^^^^^^^
[INFO] [stdout]    |             |
[INFO] [stdout]    |             help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> public_function/src/lib.rs:67:13
[INFO] [stdout]    |
[INFO] [stdout] 67 |         let mut master_slave_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]    --> public_function/src/lib.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |         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]    --> public_function/src/lib.rs:163:13
[INFO] [stdout]     |
[INFO] [stdout] 163 |         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 import: `AsyncBufReadExt`
[INFO] [stdout]   --> public_function/src/lib.rs:12:17
[INFO] [stdout]    |
[INFO] [stdout] 12 | use tokio::io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt};
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `PosttingTcpStream` should have a snake case name
[INFO] [stdout]  --> public_function/src/lib.rs:1:9
[INFO] [stdout]   |
[INFO] [stdout] 1 | pub mod PosttingTcpStream;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `postting_tcp_stream`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `RandomNumber` should have a snake case name
[INFO] [stdout]  --> public_function/src/lib.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]    Compiling daql_analysis v0.1.0 (/opt/rustwide/workdir/daql_analysis)
[INFO] [stderr]    Compiling slave v0.1.0 (/opt/rustwide/workdir/slave)
[INFO] [stderr]    Compiling data-lake-client v0.1.0 (/opt/rustwide/workdir/data-lake-client)
[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)]` 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:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 |     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]    Compiling master v0.1.0 (/opt/rustwide/workdir/master)
[INFO] [stdout] warning: unused import: `TcpSocket`
[INFO] [stdout]  --> data-lake-client/src/controls/stream_read_logic.rs:7:18
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::net::{TcpSocket, TcpStream};
[INFO] [stdout]   |                  ^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` 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] 
[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)]` 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]  --> slave/src/controls/compress_table.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use snap::raw::{Decoder, Encoder};
[INFO] [stdout]   |                 ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AsyncReadExt`
[INFO] [stdout]  --> slave/src/controls/compress_table.rs:9:17
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt};
[INFO] [stdout]   |                 ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::SLAVE_CONFIG`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use public_function::SLAVE_CONFIG;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `snap::raw::Decoder`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use snap::raw::Decoder;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::fs::OpenOptions`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::fs::OpenOptions;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncReadExt`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use tokio::io::AsyncReadExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::read_function::get_slave_path`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use public_function::read_function::get_slave_path;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::SLAVE_CONFIG`
[INFO] [stdout]  --> slave/src/controls/stream_read.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use public_function::SLAVE_CONFIG;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::mem`
[INFO] [stdout]  --> slave/src/controls/stream_read.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::mem;
[INFO] [stdout]   |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/controls/stream_read.rs:100:21
[INFO] [stdout]     |
[INFO] [stdout] 100 |     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout]     |                     ^                               ^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_parens)]` on by default
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 100 -     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout] 100 +     let mut right = index_file_len / INDEX_SIZE - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/controls/stream_read.rs:114:20
[INFO] [stdout]     |
[INFO] [stdout] 114 |             left = (mid + 1);
[INFO] [stdout]     |                    ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 114 -             left = (mid + 1);
[INFO] [stdout] 114 +             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:116:21
[INFO] [stdout]     |
[INFO] [stdout] 116 |             right = (mid - 1);
[INFO] [stdout]     |                     ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 116 -             right = (mid - 1);
[INFO] [stdout] 116 +             right = mid - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `BatchInsert` and `Insert`
[INFO] [stdout]  --> slave/src/controls/batch_insert.rs:7:40
[INFO] [stdout]   |
[INFO] [stdout] 7 | use entity_lib::entity::MasterEntity::{BatchInsert, Insert, SlaveInsert};
[INFO] [stdout]   |                                        ^^^^^^^^^^^  ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SLAVE_CONFIG`
[INFO] [stdout]  --> slave/src/mechanism/replicas.rs:7:23
[INFO] [stdout]   |
[INFO] [stdout] 7 | use public_function::{SLAVE_CONFIG, get_partition_path};
[INFO] [stdout]   |                       ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:152:21
[INFO] [stdout]     |
[INFO] [stdout] 152 |     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout]     |                     ^                               ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 152 -     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout] 152 +     let mut right = index_file_len / INDEX_SIZE - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:166:20
[INFO] [stdout]     |
[INFO] [stdout] 166 |             left = (mid + 1);
[INFO] [stdout]     |                    ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 166 -             left = (mid + 1);
[INFO] [stdout] 166 +             left = mid + 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:168:21
[INFO] [stdout]     |
[INFO] [stdout] 168 |             right = (mid - 1);
[INFO] [stdout]     |                     ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 168 -             right = (mid - 1);
[INFO] [stdout] 168 +             right = mid - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::Error::DataLakeError`
[INFO] [stdout]   --> slave/src/main.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | use entity_lib::entity::Error::DataLakeError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::MasterEntity::QueryItem`
[INFO] [stdout]   --> slave/src/main.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use entity_lib::entity::MasterEntity::QueryItem;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::SlaveEntity::SlaveMessage::drop_table`
[INFO] [stdout]   --> slave/src/main.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | use entity_lib::entity::SlaveEntity::SlaveMessage::drop_table;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `QueryMessage`
[INFO] [stdout]   --> slave/src/main.rs:13:39
[INFO] [stdout]    |
[INFO] [stdout] 13 | use entity_lib::entity::SlaveEntity::{QueryMessage, SlaveMessage};
[INFO] [stdout]    |                                       ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `error`
[INFO] [stdout]   --> slave/src/main.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | use log::{error, info};
[INFO] [stdout]    |           ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::path`
[INFO] [stdout]   --> slave/src/main.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use std::path;
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::path::Path`
[INFO] [stdout]   --> slave/src/main.rs:17:5
[INFO] [stdout]    |
[INFO] [stdout] 17 | use std::path::Path;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> slave/src/main.rs:20:5
[INFO] [stdout]    |
[INFO] [stdout] 20 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `key`
[INFO] [stdout]   --> slave/src/controls/compress_table.rs:87:10
[INFO] [stdout]    |
[INFO] [stdout] 87 |     for (key, (position, len)) in res_map.into_iter() {
[INFO] [stdout]    |          ^^^ help: if this is intentional, prefix it with an underscore: `_key`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` 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)]` on by default
[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)]` 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: unused imports: `Info` and `PartitionInfo`
[INFO] [stdout]  --> master/src/controls/compress_table.rs:4:40
[INFO] [stdout]   |
[INFO] [stdout] 4 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo};
[INFO] [stdout]   |                                        ^^^^  ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stdout]  --> master/src/controls/create.rs:2:40
[INFO] [stdout]   |
[INFO] [stdout] 2 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo, TableStructure};
[INFO] [stdout]   |                                        ^^^^  ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::array`
[INFO] [stdout]  --> master/src/controls/stream_read.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use std::array;
[INFO] [stdout]   |     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stdout]  --> master/src/controls/batch_insert.rs:3:90
[INFO] [stdout]   |
[INFO] [stdout] 3 | use entity_lib::entity::MasterEntity::{BatchInsertTruth, ColumnConfigJudgment, DataType, Info, PartitionInfo, SlaveBatchData, SlaveInsert...
[INFO] [stdout]   |                                                                                          ^^^^  ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> master/src/controls/batch_insert.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::MASTER_CONFIG`
[INFO] [stdout]  --> master/src/controls/alter.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use public_function::MASTER_CONFIG;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> master/src/controls/alter.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `PartitionInfo`
[INFO] [stdout]  --> master/src/mechanism/replicas.rs:1:46
[INFO] [stdout]   |
[INFO] [stdout] 1 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo, TableStructure};
[INFO] [stdout]   |                                              ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::Error::DataLakeError`
[INFO] [stdout]   --> master/src/main.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 | use entity_lib::entity::Error::DataLakeError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `error`
[INFO] [stdout]   --> master/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: `write_error`
[INFO] [stdout]   --> master/src/main.rs:18:69
[INFO] [stdout]    |
[INFO] [stdout] 18 | use public_function::{MASTER_CONFIG, MasterConfig, load_properties, write_error};
[INFO] [stdout]    |                                                                     ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `serde_json::json`
[INFO] [stdout]   --> master/src/main.rs:19:5
[INFO] [stdout]    |
[INFO] [stdout] 19 | use serde_json::json;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::any::Any`
[INFO] [stdout]   --> master/src/main.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::any::Any;
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> master/src/main.rs:25:5
[INFO] [stdout]    |
[INFO] [stdout] 25 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::Receiver`
[INFO] [stdout]   --> master/src/main.rs:26:5
[INFO] [stdout]    |
[INFO] [stdout] 26 | use tokio::sync::mpsc::Receiver;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/compress_table.rs:21:9
[INFO] [stdout]    |
[INFO] [stdout] 21 |     let mut log_files = public_function::get_list_filename(&table_name).await;
[INFO] [stdout]    |         ----^^^^^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` 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:27:13
[INFO] [stdout]    |
[INFO] [stdout] 27 |         let mut hash_map = HashMap::<String, i64>::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]   --> master/src/controls/compress_table.rs:25:17
[INFO] [stdout]    |
[INFO] [stdout] 25 |             let mut message = SlaveMessage::compress_table(format!("{}-{}", table_name, key));
[INFO] [stdout]    |                 ----^^^^^^^
[INFO] [stdout]    |                 |
[INFO] [stdout]    |                 help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/insert_data.rs:52:17
[INFO] [stdout]    |
[INFO] [stdout] 52 |             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/insert_data.rs:59:17
[INFO] [stdout]    |
[INFO] [stdout] 59 |             let mut metadata_mmap = unsafe {MmapMut::map_mut(&metadata_file).unwrap()};
[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/insert_data.rs:78:17
[INFO] [stdout]    |
[INFO] [stdout] 78 |             let mut log_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/insert_data.rs:85:17
[INFO] [stdout]    |
[INFO] [stdout] 85 |             let mut index_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/insert_data.rs:106:9
[INFO] [stdout]     |
[INFO] [stdout] 106 |     let mut metadata_mmap = &mut slave_cache_struct.metadata_mmap;
[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:129:13
[INFO] [stdout]     |
[INFO] [stdout] 129 |             _ =>{
[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:129:13
[INFO] [stdout]     |
[INFO] [stdout] 51  |             ClientStatement::sql(sql) => {
[INFO] [stdout]     |             ------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 85  |             ClientStatement::stream_read(stream_read) => {
[INFO] [stdout]     |             ----------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 102 |             ClientStatement::batch_insert(batch_insert) => {
[INFO] [stdout]     |             ------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 129 |             _ =>{
[INFO] [stdout]     |             ^ collectively making this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `sql`
[INFO] [stdout]   --> data-lake-client/src/main.rs:51:34
[INFO] [stdout]    |
[INFO] [stdout] 51 |             ClientStatement::sql(sql) => {
[INFO] [stdout]    |                                  ^^^ help: if this is intentional, prefix it with an underscore: `_sql`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `k`
[INFO] [stdout]   --> slave/src/controls/query_table.rs:51:16
[INFO] [stdout]    |
[INFO] [stdout] 51 |         .map(|(k, v)| {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/query_table.rs:25:9
[INFO] [stdout]    |
[INFO] [stdout] 25 |     let mut log_file = public_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/controls/query_table.rs:29:9
[INFO] [stdout]    |
[INFO] [stdout] 29 |     let mut file_vec = log_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]   --> master/src/controls/metadata.rs:12:9
[INFO] [stdout]    |
[INFO] [stdout] 12 |     let mut file = OpenOptions::new().read(true).open(&table_path).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]   --> master/src/controls/metadata.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] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/stream_read.rs:17:9
[INFO] [stdout]    |
[INFO] [stdout] 17 |     let mut log_files = public_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/controls/stream_read.rs:42:9
[INFO] [stdout]    |
[INFO] [stdout] 42 |     let mut offset = streamreadstruct.offset;
[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:43:9
[INFO] [stdout]    |
[INFO] [stdout] 43 |     let mut read_count = streamreadstruct.read_count;
[INFO] [stdout]    |         ----^^^^^^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[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]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/stream_read.rs:64:13
[INFO] [stdout]    |
[INFO] [stdout] 64 |         let mut index_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/stream_read.rs:91:9
[INFO] [stdout]    |
[INFO] [stdout] 91 |     let mut index_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/stream_read.rs:135:13
[INFO] [stdout]     |
[INFO] [stdout] 135 |         let mut stream_data = load_data(index_path, &start_index, &end_index).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:144:13
[INFO] [stdout]     |
[INFO] [stdout] 144 |         let mut stream_data = load_data(index_path, &start_index, &end_index).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:164:9
[INFO] [stdout]     |
[INFO] [stdout] 164 |     let mut data_file = OpenOptions::new().read(true).open(data_path).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/batch_insert.rs:54:21
[INFO] [stdout]    |
[INFO] [stdout] 54 |                 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:60:21
[INFO] [stdout]    |
[INFO] [stdout] 60 |                 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/batch_insert.rs:86:21
[INFO] [stdout]    |
[INFO] [stdout] 86 |                 let mut log_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:93:21
[INFO] [stdout]    |
[INFO] [stdout] 93 |                 let mut index_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:116:13
[INFO] [stdout]     |
[INFO] [stdout] 116 |         let mut metadata_mmap = &mut slave_cache_struct.metadata_mmap;
[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:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     let mut metadata_mmap = &mut mutex_map.get_mut(&file_key).unwrap().metadata_mmap;
[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:23:9
[INFO] [stdout]    |
[INFO] [stdout] 23 |     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/mechanism/replicas.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut log_files = public_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/mechanism/replicas.rs:142:9
[INFO] [stdout]     |
[INFO] [stdout] 142 |     let mut index_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/mechanism/replicas.rs:181:9
[INFO] [stdout]     |
[INFO] [stdout] 181 |     let mut snappy_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]   --> master/src/controls/stream_read.rs:80:25
[INFO] [stdout]    |
[INFO] [stdout] 80 |                     let mut stream = TcpStream::connect(address).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]   --> master/src/controls/stream_read.rs:29:18
[INFO] [stdout]    |
[INFO] [stdout] 29 |     let (sender, mut receiver) = tokio::sync::mpsc::channel::<Option<Vec<u8>>>(10000);
[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]   --> master/src/controls/batch_insert.rs:52:21
[INFO] [stdout]    |
[INFO] [stdout] 52 |                 let mut stream = DataLakeTcpStream::connect(partition_info_vec).await?;
[INFO] [stdout]    |                     ----^^^^^^
[INFO] [stdout]    |                     |
[INFO] [stdout]    |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AsyncReadExt`
[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: unnecessary `unsafe` block
[INFO] [stdout]   --> slave/src/main.rs:54:9
[INFO] [stdout]    |
[INFO] [stdout] 54 |         unsafe {
[INFO] [stdout]    |         ^^^^^^ unnecessary `unsafe` block
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_unsafe)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stdout]  --> master/src/controls/batch_insert.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use tokio::io::AsyncWriteExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` in tuple element 0 that must be used
[INFO] [stdout]   --> slave/src/main.rs:67:5
[INFO] [stdout]    |
[INFO] [stdout] 67 |     tokio::join!(slave);
[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)]` on by default
[INFO] [stdout]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `tmpfile_offsetCode` should have a snake case name
[INFO] [stdout]   --> slave/src/controls/compress_table.rs:60:13
[INFO] [stdout]    |
[INFO] [stdout] 60 |     let mut tmpfile_offsetCode = HashMap::<String, i64>::new();
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `tmpfile_offset_code`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `Index_struct` should have a snake case name
[INFO] [stdout]   --> slave/src/controls/stream_read.rs:75:13
[INFO] [stdout]    |
[INFO] [stdout] 75 |         let Index_struct = bincode::deserialize::<IndexStruct>(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:83:17
[INFO] [stdout]    |
[INFO] [stdout] 83 |             let end_Index_struct = bincode::deserialize::<IndexStruct>(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:101:14
[INFO] [stdout]     |
[INFO] [stdout] 101 | pub async fn Leader_replicas_sync(sync_message: &SyncMessage) -> Option<ReplicaseSyncData> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `leader_replicas_sync`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> master/src/controls/batch_insert.rs:206:9
[INFO] [stdout]     |
[INFO] [stdout] 206 |         _ => {
[INFO] [stdout]     |         ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> master/src/controls/batch_insert.rs:206:9
[INFO] [stdout]     |
[INFO] [stdout] 167 |         DataType::string => {
[INFO] [stdout]     |         ---------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 170 |         DataType::int => match col_value.parse::<i32>() {
[INFO] [stdout]     |         ------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 179 |         DataType::float => match col_value.parse::<f32>() {
[INFO] [stdout]     |         --------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 188 |         DataType::boolean => match col_value.parse::<bool>() {
[INFO] [stdout]     |         ----------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 206 |         _ => {
[INFO] [stdout]     |         ^ ...and 1 other patterns collectively make this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> master/src/controls/batch_insert.rs:172:17
[INFO] [stdout]     |
[INFO] [stdout] 172 |             Err(e) => {
[INFO] [stdout]     |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> master/src/mechanism/replicas.rs:40:25
[INFO] [stdout]    |
[INFO] [stdout] 40 |                     let mut mmap = unsafe { Mmap::map(&file) }.unwrap();
[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]   --> master/src/mechanism/replicas.rs:33:21
[INFO] [stdout]    |
[INFO] [stdout] 33 |                 let mut file = OpenOptions::new()
[INFO] [stdout]    |                     ----^^^^
[INFO] [stdout]    |                     |
[INFO] [stdout]    |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary `unsafe` block
[INFO] [stdout]   --> master/src/main.rs:57:9
[INFO] [stdout]    |
[INFO] [stdout] 57 |         unsafe {
[INFO] [stdout]    |         ^^^^^^ unnecessary `unsafe` block
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_unsafe)]` 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:68:5
[INFO] [stdout]    |
[INFO] [stdout] 68 |     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)]` on by default
[INFO] [stdout]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` in tuple element 1 that must be used
[INFO] [stdout]   --> master/src/main.rs:68:5
[INFO] [stdout]    |
[INFO] [stdout] 68 |     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: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `dev` profile [unoptimized + debuginfo] target(s) in 19.01s
[INFO] running `Command { std: "docker" "inspect" "02153124d263911211df4bd09a82f961187877cf2d42fb5a2b127287014d68bc", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "02153124d263911211df4bd09a82f961187877cf2d42fb5a2b127287014d68bc", kill_on_drop: false }`
[INFO] [stdout] 02153124d263911211df4bd09a82f961187877cf2d42fb5a2b127287014d68bc
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:90999bfc7ae267e83380e433d8e61a7c072ca6729e92edbae886d3423b3a6f4c" "/opt/rustwide/cargo-home/bin/cargo" "+8de4c7234dd9b97c9d76b58671343fdbbc9a433e" "test" "--frozen" "--no-run" "--message-format=json" "--target" "x86_64-unknown-linux-musl", kill_on_drop: false }`
[INFO] [stdout] 2a4bb6aaa56012b3510e552c53b53bf5daca6182d35de9c76a6f5d470a0e2ad5
[INFO] running `Command { std: "docker" "start" "-a" "2a4bb6aaa56012b3510e552c53b53bf5daca6182d35de9c76a6f5d470a0e2ad5", 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] 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] [stdout] warning: variant `string` should have an upper camel case name
[INFO] [stdout]  --> entity_lib/src/entity/MasterEntity.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 |     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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `int` should have an upper camel case name
[INFO] [stdout]  --> entity_lib/src/entity/MasterEntity.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 |     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]  --> entity_lib/src/entity/MasterEntity.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 |     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]  --> entity_lib/src/entity/MasterEntity.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 |     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]   --> entity_lib/src/entity/MasterEntity.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 |     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]   --> entity_lib/src/entity/MasterEntity.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 |     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]   --> entity_lib/src/entity/MasterEntity.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 |     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]   --> entity_lib/src/entity/MasterEntity.rs:98:5
[INFO] [stdout]    |
[INFO] [stdout] 98 |     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]   --> entity_lib/src/entity/MasterEntity.rs:99:5
[INFO] [stdout]    |
[INFO] [stdout] 99 |     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]    --> entity_lib/src/entity/MasterEntity.rs:100:5
[INFO] [stdout]     |
[INFO] [stdout] 100 |     batch_insert(BatchInsert)
[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]    --> entity_lib/src/entity/MasterEntity.rs:157:5
[INFO] [stdout]     |
[INFO] [stdout] 157 |     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]    --> entity_lib/src/entity/MasterEntity.rs:158:5
[INFO] [stdout]     |
[INFO] [stdout] 158 |     column(Vec<String>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:159:5
[INFO] [stdout]     |
[INFO] [stdout] 159 |     term(HashMap<String, serde_json::Value>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:160:5
[INFO] [stdout]     |
[INFO] [stdout] 160 |     gt(HashMap<String, serde_json::Value>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:161:5
[INFO] [stdout]     |
[INFO] [stdout] 161 |     lt(HashMap<String, serde_json::Value>),
[INFO] [stdout]     |     ^^ help: convert the identifier to upper camel case: `Lt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `QueryItem`
[INFO] [stdout]  --> entity_lib/src/entity/SlaveEntity.rs:4:43
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::entity::MasterEntity::{Insert, QueryItem, SlaveInsert};
[INFO] [stdout]   |                                           ^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `create` should have an upper camel case name
[INFO] [stdout]   --> entity_lib/src/entity/SlaveEntity.rs:29:5
[INFO] [stdout]    |
[INFO] [stdout] 29 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:30:5
[INFO] [stdout]    |
[INFO] [stdout] 30 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:31:5
[INFO] [stdout]    |
[INFO] [stdout] 31 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:32:5
[INFO] [stdout]    |
[INFO] [stdout] 32 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:33:5
[INFO] [stdout]    |
[INFO] [stdout] 33 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:34:5
[INFO] [stdout]    |
[INFO] [stdout] 34 |     batch_insert(SlaveInsert),
[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]   --> entity_lib/src/entity/SlaveEntity.rs:35:5
[INFO] [stdout]    |
[INFO] [stdout] 35 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:36:5
[INFO] [stdout]    |
[INFO] [stdout] 36 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:37:5
[INFO] [stdout]    |
[INFO] [stdout] 37 |     leader_replicas_sync(SyncMessage),
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `LeaderReplicasSync`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `CREATE_TABLE` should have an upper camel case name
[INFO] [stdout]  --> entity_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]  --> entity_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]  --> entity_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]   --> entity_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 `SHOW_TABLE` should have an upper camel case name
[INFO] [stdout]   --> entity_lib/src/entity/DaqlEntity.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     SHOW_TABLE(String),
[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]   --> entity_lib/src/entity/DaqlEntity.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 |     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]   --> entity_lib/src/entity/DaqlEntity.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     DROP_TABLE(String),
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Deserialize` and `Serialize`
[INFO] [stdout]  --> entity_lib/src/entity/mod.rs:7:13
[INFO] [stdout]   |
[INFO] [stdout] 7 | use serde::{Deserialize, Serialize};
[INFO] [stdout]   |             ^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `crate::entity::MasterEntity::Statement`
[INFO] [stdout]  --> entity_lib/src/entity/mod.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use crate::entity::MasterEntity::Statement;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `MasterEntity` should have a snake case name
[INFO] [stdout]  --> entity_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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `SlaveEntity` should have a snake case name
[INFO] [stdout]  --> entity_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]  --> entity_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]  --> entity_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] [stderr]    Compiling entity_lib v0.1.0 (/opt/rustwide/workdir/entity_lib)
[INFO] [stdout] warning: unused import: `SlaveConfig`
[INFO] [stdout]  --> public_function/src/read_function.rs:1:13
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::{SlaveConfig, SLAVE_CONFIG};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `uuid::Uuid`
[INFO] [stdout]   --> public_function/src/read_function.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use uuid::Uuid;
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::iter::Map`
[INFO] [stdout]  --> public_function/src/lib.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use std::iter::Map;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::net::ToSocketAddrs`
[INFO] [stdout]  --> public_function/src/lib.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use std::net::ToSocketAddrs;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> public_function/src/lib.rs:49:13
[INFO] [stdout]    |
[INFO] [stdout] 49 |         let mut data_path_index = self.data_path_index;
[INFO] [stdout]    |             ----^^^^^^^^^^^^^^^
[INFO] [stdout]    |             |
[INFO] [stdout]    |             help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> public_function/src/lib.rs:67:13
[INFO] [stdout]    |
[INFO] [stdout] 67 |         let mut master_slave_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]    --> public_function/src/lib.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |         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]    --> public_function/src/lib.rs:163:13
[INFO] [stdout]     |
[INFO] [stdout] 163 |         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 import: `AsyncBufReadExt`
[INFO] [stdout]   --> public_function/src/lib.rs:12:17
[INFO] [stdout]    |
[INFO] [stdout] 12 | use tokio::io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt};
[INFO] [stdout]    |                 ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `PosttingTcpStream` should have a snake case name
[INFO] [stdout]  --> public_function/src/lib.rs:1:9
[INFO] [stdout]   |
[INFO] [stdout] 1 | pub mod PosttingTcpStream;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `postting_tcp_stream`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `RandomNumber` should have a snake case name
[INFO] [stdout]  --> public_function/src/lib.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]    Compiling public_function v0.1.0 (/opt/rustwide/workdir/public_function)
[INFO] [stderr]    Compiling data-lake-client v0.1.0 (/opt/rustwide/workdir/data-lake-client)
[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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]    Compiling daql_analysis v0.1.0 (/opt/rustwide/workdir/daql_analysis)
[INFO] [stdout] warning: variable `col_type_Identification` should have a snake case name
[INFO] [stdout]   --> daql_analysis/src/analysis/create_daql.rs:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 |     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]    Compiling master v0.1.0 (/opt/rustwide/workdir/master)
[INFO] [stderr]    Compiling slave v0.1.0 (/opt/rustwide/workdir/slave)
[INFO] [stdout] warning: unused import: `TcpSocket`
[INFO] [stdout]  --> data-lake-client/src/controls/stream_read_logic.rs:7:18
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::net::{TcpSocket, TcpStream};
[INFO] [stdout]   |                  ^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` 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] 
[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)]` 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: `SlaveConfig`
[INFO] [stdout]  --> public_function/src/read_function.rs:1:13
[INFO] [stdout]   |
[INFO] [stdout] 1 | use crate::{SlaveConfig, SLAVE_CONFIG};
[INFO] [stdout]   |             ^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `uuid::Uuid`
[INFO] [stdout]   --> public_function/src/read_function.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use uuid::Uuid;
[INFO] [stdout]    |     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::iter::Map`
[INFO] [stdout]  --> public_function/src/lib.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use std::iter::Map;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::net::ToSocketAddrs`
[INFO] [stdout]  --> public_function/src/lib.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use std::net::ToSocketAddrs;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[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)]` on by default
[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)]` 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]   --> data-lake-client/src/controls/stream_read_logic.rs:27:13
[INFO] [stdout]    |
[INFO] [stdout] 27 |         let mut hash_map = HashMap::<String, i64>::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]   --> public_function/src/lib.rs:49:13
[INFO] [stdout]    |
[INFO] [stdout] 49 |         let mut data_path_index = self.data_path_index;
[INFO] [stdout]    |             ----^^^^^^^^^^^^^^^
[INFO] [stdout]    |             |
[INFO] [stdout]    |             help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> public_function/src/lib.rs:67:13
[INFO] [stdout]    |
[INFO] [stdout] 67 |         let mut master_slave_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]    --> public_function/src/lib.rs:105:13
[INFO] [stdout]     |
[INFO] [stdout] 105 |         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]    --> public_function/src/lib.rs:163:13
[INFO] [stdout]     |
[INFO] [stdout] 163 |         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: unreachable pattern
[INFO] [stdout]    --> data-lake-client/src/main.rs:129:13
[INFO] [stdout]     |
[INFO] [stdout] 129 |             _ =>{
[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:129:13
[INFO] [stdout]     |
[INFO] [stdout] 51  |             ClientStatement::sql(sql) => {
[INFO] [stdout]     |             ------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 85  |             ClientStatement::stream_read(stream_read) => {
[INFO] [stdout]     |             ----------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 102 |             ClientStatement::batch_insert(batch_insert) => {
[INFO] [stdout]     |             ------------------------------------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 129 |             _ =>{
[INFO] [stdout]     |             ^ collectively making this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `sql`
[INFO] [stdout]   --> data-lake-client/src/main.rs:51:34
[INFO] [stdout]    |
[INFO] [stdout] 51 |             ClientStatement::sql(sql) => {
[INFO] [stdout]    |                                  ^^^ help: if this is intentional, prefix it with an underscore: `_sql`
[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]   = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `string` should have an upper camel case name
[INFO] [stdout]  --> entity_lib/src/entity/MasterEntity.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 |     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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `int` should have an upper camel case name
[INFO] [stdout]  --> entity_lib/src/entity/MasterEntity.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 |     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]  --> entity_lib/src/entity/MasterEntity.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 |     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]  --> entity_lib/src/entity/MasterEntity.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 |     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]   --> entity_lib/src/entity/MasterEntity.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 |     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]   --> entity_lib/src/entity/MasterEntity.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 |     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]   --> entity_lib/src/entity/MasterEntity.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 |     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]   --> entity_lib/src/entity/MasterEntity.rs:98:5
[INFO] [stdout]    |
[INFO] [stdout] 98 |     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]   --> entity_lib/src/entity/MasterEntity.rs:99:5
[INFO] [stdout]    |
[INFO] [stdout] 99 |     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]    --> entity_lib/src/entity/MasterEntity.rs:100:5
[INFO] [stdout]     |
[INFO] [stdout] 100 |     batch_insert(BatchInsert)
[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]    --> entity_lib/src/entity/MasterEntity.rs:157:5
[INFO] [stdout]     |
[INFO] [stdout] 157 |     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]    --> entity_lib/src/entity/MasterEntity.rs:158:5
[INFO] [stdout]     |
[INFO] [stdout] 158 |     column(Vec<String>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:159:5
[INFO] [stdout]     |
[INFO] [stdout] 159 |     term(HashMap<String, serde_json::Value>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:160:5
[INFO] [stdout]     |
[INFO] [stdout] 160 |     gt(HashMap<String, serde_json::Value>),
[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]    --> entity_lib/src/entity/MasterEntity.rs:161:5
[INFO] [stdout]     |
[INFO] [stdout] 161 |     lt(HashMap<String, serde_json::Value>),
[INFO] [stdout]     |     ^^ help: convert the identifier to upper camel case: `Lt`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `QueryItem`
[INFO] [stdout]  --> entity_lib/src/entity/SlaveEntity.rs:4:43
[INFO] [stdout]   |
[INFO] [stdout] 4 | use crate::entity::MasterEntity::{Insert, QueryItem, SlaveInsert};
[INFO] [stdout]   |                                           ^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `create` should have an upper camel case name
[INFO] [stdout]   --> entity_lib/src/entity/SlaveEntity.rs:29:5
[INFO] [stdout]    |
[INFO] [stdout] 29 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:30:5
[INFO] [stdout]    |
[INFO] [stdout] 30 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:31:5
[INFO] [stdout]    |
[INFO] [stdout] 31 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:32:5
[INFO] [stdout]    |
[INFO] [stdout] 32 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:33:5
[INFO] [stdout]    |
[INFO] [stdout] 33 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:34:5
[INFO] [stdout]    |
[INFO] [stdout] 34 |     batch_insert(SlaveInsert),
[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]   --> entity_lib/src/entity/SlaveEntity.rs:35:5
[INFO] [stdout]    |
[INFO] [stdout] 35 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:36:5
[INFO] [stdout]    |
[INFO] [stdout] 36 |     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]   --> entity_lib/src/entity/SlaveEntity.rs:37:5
[INFO] [stdout]    |
[INFO] [stdout] 37 |     leader_replicas_sync(SyncMessage),
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `LeaderReplicasSync`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant `CREATE_TABLE` should have an upper camel case name
[INFO] [stdout]  --> entity_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]  --> entity_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]  --> entity_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]   --> entity_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 `SHOW_TABLE` should have an upper camel case name
[INFO] [stdout]   --> entity_lib/src/entity/DaqlEntity.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 |     SHOW_TABLE(String),
[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]   --> entity_lib/src/entity/DaqlEntity.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 |     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]   --> entity_lib/src/entity/DaqlEntity.rs:13:5
[INFO] [stdout]    |
[INFO] [stdout] 13 |     DROP_TABLE(String),
[INFO] [stdout]    |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Deserialize` and `Serialize`
[INFO] [stdout]  --> entity_lib/src/entity/mod.rs:7:13
[INFO] [stdout]   |
[INFO] [stdout] 7 | use serde::{Deserialize, Serialize};
[INFO] [stdout]   |             ^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AsyncBufReadExt`
[INFO] [stdout]   --> public_function/src/lib.rs:12:17
[INFO] [stdout]    |
[INFO] [stdout] 12 | use tokio::io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt};
[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)]` 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:16:9
[INFO] [stdout]    |
[INFO] [stdout] 16 |     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: `Decoder`
[INFO] [stdout]  --> slave/src/controls/compress_table.rs:5:17
[INFO] [stdout]   |
[INFO] [stdout] 5 | use snap::raw::{Decoder, Encoder};
[INFO] [stdout]   |                 ^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stdout]  --> master/src/controls/compress_table.rs:4:40
[INFO] [stdout]   |
[INFO] [stdout] 4 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo};
[INFO] [stdout]   |                                        ^^^^  ^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `PosttingTcpStream` should have a snake case name
[INFO] [stdout]  --> public_function/src/lib.rs:1:9
[INFO] [stdout]   |
[INFO] [stdout] 1 | pub mod PosttingTcpStream;
[INFO] [stdout]   |         ^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `postting_tcp_stream`
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `RandomNumber` should have a snake case name
[INFO] [stdout]  --> public_function/src/lib.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: unused imports: `Info` and `PartitionInfo`
[INFO] [stdout]  --> master/src/controls/create.rs:2:40
[INFO] [stdout]   |
[INFO] [stdout] 2 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo, TableStructure};
[INFO] [stdout]   |                                        ^^^^  ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::array`
[INFO] [stdout]  --> master/src/controls/stream_read.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use std::array;
[INFO] [stdout]   |     ^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AsyncReadExt`
[INFO] [stdout]  --> slave/src/controls/compress_table.rs:9:17
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt};
[INFO] [stdout]   |                 ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::SLAVE_CONFIG`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use public_function::SLAVE_CONFIG;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `snap::raw::Decoder`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use snap::raw::Decoder;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::fs::OpenOptions`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:7:5
[INFO] [stdout]   |
[INFO] [stdout] 7 | use tokio::fs::OpenOptions;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncReadExt`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use tokio::io::AsyncReadExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::read_function::get_slave_path`
[INFO] [stdout]  --> slave/src/controls/query_table.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use public_function::read_function::get_slave_path;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::SLAVE_CONFIG`
[INFO] [stdout]  --> slave/src/controls/stream_read.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use public_function::SLAVE_CONFIG;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::mem`
[INFO] [stdout]  --> slave/src/controls/stream_read.rs:5:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use std::mem;
[INFO] [stdout]   |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/controls/stream_read.rs:100:21
[INFO] [stdout]     |
[INFO] [stdout] 100 |     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout]     |                     ^                               ^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_parens)]` on by default
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 100 -     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout] 100 +     let mut right = index_file_len / INDEX_SIZE - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/controls/stream_read.rs:114:20
[INFO] [stdout]     |
[INFO] [stdout] 114 |             left = (mid + 1);
[INFO] [stdout]     |                    ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 114 -             left = (mid + 1);
[INFO] [stdout] 114 +             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:116:21
[INFO] [stdout]     |
[INFO] [stdout] 116 |             right = (mid - 1);
[INFO] [stdout]     |                     ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 116 -             right = (mid - 1);
[INFO] [stdout] 116 +             right = mid - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stdout]  --> master/src/controls/batch_insert.rs:3:90
[INFO] [stdout]   |
[INFO] [stdout] 3 | use entity_lib::entity::MasterEntity::{BatchInsertTruth, ColumnConfigJudgment, DataType, Info, PartitionInfo, SlaveBatchData, SlaveInsert...
[INFO] [stdout]   |                                                                                          ^^^^  ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused imports: `BatchInsert` and `Insert`
[INFO] [stdout]  --> slave/src/controls/batch_insert.rs:7:40
[INFO] [stdout]   |
[INFO] [stdout] 7 | use entity_lib::entity::MasterEntity::{BatchInsert, Insert, SlaveInsert};
[INFO] [stdout]   |                                        ^^^^^^^^^^^  ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `SLAVE_CONFIG`
[INFO] [stdout]  --> slave/src/mechanism/replicas.rs:7:23
[INFO] [stdout]   |
[INFO] [stdout] 7 | use public_function::{SLAVE_CONFIG, get_partition_path};
[INFO] [stdout]   |                       ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:152:21
[INFO] [stdout]     |
[INFO] [stdout] 152 |     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout]     |                     ^                               ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 152 -     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stdout] 152 +     let mut right = index_file_len / INDEX_SIZE - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:166:20
[INFO] [stdout]     |
[INFO] [stdout] 166 |             left = (mid + 1);
[INFO] [stdout]     |                    ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 166 -             left = (mid + 1);
[INFO] [stdout] 166 +             left = mid + 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary parentheses around assigned value
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:168:21
[INFO] [stdout]     |
[INFO] [stdout] 168 |             right = (mid - 1);
[INFO] [stdout]     |                     ^       ^
[INFO] [stdout]     |
[INFO] [stdout] help: remove these parentheses
[INFO] [stdout]     |
[INFO] [stdout] 168 -             right = (mid - 1);
[INFO] [stdout] 168 +             right = mid - 1;
[INFO] [stdout]     |
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::Error::DataLakeError`
[INFO] [stdout]   --> slave/src/main.rs:10:5
[INFO] [stdout]    |
[INFO] [stdout] 10 | use entity_lib::entity::Error::DataLakeError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::MasterEntity::QueryItem`
[INFO] [stdout]   --> slave/src/main.rs:11:5
[INFO] [stdout]    |
[INFO] [stdout] 11 | use entity_lib::entity::MasterEntity::QueryItem;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::SlaveEntity::SlaveMessage::drop_table`
[INFO] [stdout]   --> slave/src/main.rs:12:5
[INFO] [stdout]    |
[INFO] [stdout] 12 | use entity_lib::entity::SlaveEntity::SlaveMessage::drop_table;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `QueryMessage`
[INFO] [stdout]   --> slave/src/main.rs:13:39
[INFO] [stdout]    |
[INFO] [stdout] 13 | use entity_lib::entity::SlaveEntity::{QueryMessage, SlaveMessage};
[INFO] [stdout]    |                                       ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `error`
[INFO] [stdout]   --> slave/src/main.rs:14:11
[INFO] [stdout]    |
[INFO] [stdout] 14 | use log::{error, info};
[INFO] [stdout]    |           ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::path`
[INFO] [stdout]   --> slave/src/main.rs:16:5
[INFO] [stdout]    |
[INFO] [stdout] 16 | use std::path;
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::path::Path`
[INFO] [stdout]   --> slave/src/main.rs:17:5
[INFO] [stdout]    |
[INFO] [stdout] 17 | use std::path::Path;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> slave/src/main.rs:20:5
[INFO] [stdout]    |
[INFO] [stdout] 20 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> master/src/controls/batch_insert.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `public_function::MASTER_CONFIG`
[INFO] [stdout]  --> master/src/controls/alter.rs:3:5
[INFO] [stdout]   |
[INFO] [stdout] 3 | use public_function::MASTER_CONFIG;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::net::TcpStream`
[INFO] [stdout]  --> master/src/controls/alter.rs:6:5
[INFO] [stdout]   |
[INFO] [stdout] 6 | use tokio::net::TcpStream;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `PartitionInfo`
[INFO] [stdout]  --> master/src/mechanism/replicas.rs:1:46
[INFO] [stdout]   |
[INFO] [stdout] 1 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo, TableStructure};
[INFO] [stdout]   |                                              ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `entity_lib::entity::Error::DataLakeError`
[INFO] [stdout]   --> master/src/main.rs:15:5
[INFO] [stdout]    |
[INFO] [stdout] 15 | use entity_lib::entity::Error::DataLakeError;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `error`
[INFO] [stdout]   --> master/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: `write_error`
[INFO] [stdout]   --> master/src/main.rs:18:69
[INFO] [stdout]    |
[INFO] [stdout] 18 | use public_function::{MASTER_CONFIG, MasterConfig, load_properties, write_error};
[INFO] [stdout]    |                                                                     ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `serde_json::json`
[INFO] [stdout]   --> master/src/main.rs:19:5
[INFO] [stdout]    |
[INFO] [stdout] 19 | use serde_json::json;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::any::Any`
[INFO] [stdout]   --> master/src/main.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 | use std::any::Any;
[INFO] [stdout]    |     ^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::Mutex`
[INFO] [stdout]   --> master/src/main.rs:25:5
[INFO] [stdout]    |
[INFO] [stdout] 25 | use tokio::sync::Mutex;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::sync::mpsc::Receiver`
[INFO] [stdout]   --> master/src/main.rs:26:5
[INFO] [stdout]    |
[INFO] [stdout] 26 | use tokio::sync::mpsc::Receiver;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> master/src/controls/compress_table.rs:25:17
[INFO] [stdout]    |
[INFO] [stdout] 25 |             let mut message = SlaveMessage::compress_table(format!("{}-{}", table_name, key));
[INFO] [stdout]    |                 ----^^^^^^^
[INFO] [stdout]    |                 |
[INFO] [stdout]    |                 help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> master/src/controls/metadata.rs:12:9
[INFO] [stdout]    |
[INFO] [stdout] 12 |     let mut file = OpenOptions::new().read(true).open(&table_path).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]   --> master/src/controls/metadata.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] 
[INFO] [stdout] warning: unused variable: `key`
[INFO] [stdout]   --> slave/src/controls/compress_table.rs:87:10
[INFO] [stdout]    |
[INFO] [stdout] 87 |     for (key, (position, len)) in res_map.into_iter() {
[INFO] [stdout]    |          ^^^ help: if this is intentional, prefix it with an underscore: `_key`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/compress_table.rs:21:9
[INFO] [stdout]    |
[INFO] [stdout] 21 |     let mut log_files = public_function::get_list_filename(&table_name).await;
[INFO] [stdout]    |         ----^^^^^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> master/src/controls/stream_read.rs:80:25
[INFO] [stdout]    |
[INFO] [stdout] 80 |                     let mut stream = TcpStream::connect(address).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]   --> master/src/controls/stream_read.rs:29:18
[INFO] [stdout]    |
[INFO] [stdout] 29 |     let (sender, mut receiver) = tokio::sync::mpsc::channel::<Option<Vec<u8>>>(10000);
[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]   --> master/src/controls/batch_insert.rs:52:21
[INFO] [stdout]    |
[INFO] [stdout] 52 |                 let mut stream = DataLakeTcpStream::connect(partition_info_vec).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/insert_data.rs:52:17
[INFO] [stdout]    |
[INFO] [stdout] 52 |             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/insert_data.rs:59:17
[INFO] [stdout]    |
[INFO] [stdout] 59 |             let mut metadata_mmap = unsafe {MmapMut::map_mut(&metadata_file).unwrap()};
[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/insert_data.rs:78:17
[INFO] [stdout]    |
[INFO] [stdout] 78 |             let mut log_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/insert_data.rs:85:17
[INFO] [stdout]    |
[INFO] [stdout] 85 |             let mut index_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/insert_data.rs:106:9
[INFO] [stdout]     |
[INFO] [stdout] 106 |     let mut metadata_mmap = &mut slave_cache_struct.metadata_mmap;
[INFO] [stdout]     |         ----^^^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `k`
[INFO] [stdout]   --> slave/src/controls/query_table.rs:51:16
[INFO] [stdout]    |
[INFO] [stdout] 51 |         .map(|(k, v)| {
[INFO] [stdout]    |                ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/query_table.rs:25:9
[INFO] [stdout]    |
[INFO] [stdout] 25 |     let mut log_file = public_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/controls/query_table.rs:29:9
[INFO] [stdout]    |
[INFO] [stdout] 29 |     let mut file_vec = log_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/stream_read.rs:17:9
[INFO] [stdout]    |
[INFO] [stdout] 17 |     let mut log_files = public_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/controls/stream_read.rs:42:9
[INFO] [stdout]    |
[INFO] [stdout] 42 |     let mut offset = streamreadstruct.offset;
[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:43:9
[INFO] [stdout]    |
[INFO] [stdout] 43 |     let mut read_count = streamreadstruct.read_count;
[INFO] [stdout]    |         ----^^^^^^^^^^
[INFO] [stdout]    |         |
[INFO] [stdout]    |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stdout]  --> master/src/controls/batch_insert.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use tokio::io::AsyncWriteExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/stream_read.rs:64:13
[INFO] [stdout]    |
[INFO] [stdout] 64 |         let mut index_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/stream_read.rs:91:9
[INFO] [stdout]    |
[INFO] [stdout] 91 |     let mut index_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/stream_read.rs:135:13
[INFO] [stdout]     |
[INFO] [stdout] 135 |         let mut stream_data = load_data(index_path, &start_index, &end_index).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:144:13
[INFO] [stdout]     |
[INFO] [stdout] 144 |         let mut stream_data = load_data(index_path, &start_index, &end_index).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:164:9
[INFO] [stdout]     |
[INFO] [stdout] 164 |     let mut data_file = OpenOptions::new().read(true).open(data_path).await?;
[INFO] [stdout]     |         ----^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unreachable pattern
[INFO] [stdout]    --> master/src/controls/batch_insert.rs:206:9
[INFO] [stdout]     |
[INFO] [stdout] 206 |         _ => {
[INFO] [stdout]     |         ^ no value can reach this
[INFO] [stdout]     |
[INFO] [stdout] note: multiple earlier patterns match some of the same values
[INFO] [stdout]    --> master/src/controls/batch_insert.rs:206:9
[INFO] [stdout]     |
[INFO] [stdout] 167 |         DataType::string => {
[INFO] [stdout]     |         ---------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 170 |         DataType::int => match col_value.parse::<i32>() {
[INFO] [stdout]     |         ------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 179 |         DataType::float => match col_value.parse::<f32>() {
[INFO] [stdout]     |         --------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 188 |         DataType::boolean => match col_value.parse::<bool>() {
[INFO] [stdout]     |         ----------------- matches some of the same values
[INFO] [stdout] ...
[INFO] [stdout] 206 |         _ => {
[INFO] [stdout]     |         ^ ...and 1 other patterns collectively make this unreachable
[INFO] [stdout]     = note: `#[warn(unreachable_patterns)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused variable: `e`
[INFO] [stdout]    --> master/src/controls/batch_insert.rs:172:17
[INFO] [stdout]     |
[INFO] [stdout] 172 |             Err(e) => {
[INFO] [stdout]     |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> master/src/mechanism/replicas.rs:40:25
[INFO] [stdout]    |
[INFO] [stdout] 40 |                     let mut mmap = unsafe { Mmap::map(&file) }.unwrap();
[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]   --> master/src/mechanism/replicas.rs:33:21
[INFO] [stdout]    |
[INFO] [stdout] 33 |                 let mut file = OpenOptions::new()
[INFO] [stdout]    |                     ----^^^^
[INFO] [stdout]    |                     |
[INFO] [stdout]    |                     help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unnecessary `unsafe` block
[INFO] [stdout]   --> master/src/main.rs:57:9
[INFO] [stdout]    |
[INFO] [stdout] 57 |         unsafe {
[INFO] [stdout]    |         ^^^^^^ unnecessary `unsafe` block
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_unsafe)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]   --> slave/src/controls/batch_insert.rs:54:21
[INFO] [stdout]    |
[INFO] [stdout] 54 |                 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:60:21
[INFO] [stdout]    |
[INFO] [stdout] 60 |                 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/batch_insert.rs:86:21
[INFO] [stdout]    |
[INFO] [stdout] 86 |                 let mut log_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:93:21
[INFO] [stdout]    |
[INFO] [stdout] 93 |                 let mut index_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:116:13
[INFO] [stdout]     |
[INFO] [stdout] 116 |         let mut metadata_mmap = &mut slave_cache_struct.metadata_mmap;
[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:182:9
[INFO] [stdout]     |
[INFO] [stdout] 182 |     let mut metadata_mmap = &mut mutex_map.get_mut(&file_key).unwrap().metadata_mmap;
[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:23:9
[INFO] [stdout]    |
[INFO] [stdout] 23 |     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/mechanism/replicas.rs:105:9
[INFO] [stdout]     |
[INFO] [stdout] 105 |     let mut log_files = public_function::get_list_filename(&partition_code).await;
[INFO] [stdout]     |         ----^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` in tuple element 0 that must be used
[INFO] [stdout]   --> master/src/main.rs:68:5
[INFO] [stdout]    |
[INFO] [stdout] 68 |     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)]` on by default
[INFO] [stdout]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused `Result` in tuple element 1 that must be used
[INFO] [stdout]   --> master/src/main.rs:68:5
[INFO] [stdout]    |
[INFO] [stdout] 68 |     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: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable does not need to be mutable
[INFO] [stdout]    --> slave/src/mechanism/replicas.rs:142:9
[INFO] [stdout]     |
[INFO] [stdout] 142 |     let mut index_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/mechanism/replicas.rs:181:9
[INFO] [stdout]     |
[INFO] [stdout] 181 |     let mut snappy_file = OpenOptions::new()
[INFO] [stdout]     |         ----^^^^^^^^^^^
[INFO] [stdout]     |         |
[INFO] [stdout]     |         help: remove this `mut`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `AsyncReadExt`
[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: module `MasterEntity` should have a snake case name
[INFO] [stdout]  --> entity_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)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: module `SlaveEntity` should have a snake case name
[INFO] [stdout]  --> entity_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]  --> entity_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]  --> entity_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: unnecessary `unsafe` block
[INFO] [stdout]   --> slave/src/main.rs:54:9
[INFO] [stdout]    |
[INFO] [stdout] 54 |         unsafe {
[INFO] [stdout]    |         ^^^^^^ unnecessary `unsafe` block
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(unused_unsafe)]` 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:67:5
[INFO] [stdout]    |
[INFO] [stdout] 67 |     tokio::join!(slave);
[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)]` on by default
[INFO] [stdout]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `tmpfile_offsetCode` should have a snake case name
[INFO] [stdout]   --> slave/src/controls/compress_table.rs:60:13
[INFO] [stdout]    |
[INFO] [stdout] 60 |     let mut tmpfile_offsetCode = HashMap::<String, i64>::new();
[INFO] [stdout]    |             ^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `tmpfile_offset_code`
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(non_snake_case)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variable `Index_struct` should have a snake case name
[INFO] [stdout]   --> slave/src/controls/stream_read.rs:75:13
[INFO] [stdout]    |
[INFO] [stdout] 75 |         let Index_struct = bincode::deserialize::<IndexStruct>(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:83:17
[INFO] [stdout]    |
[INFO] [stdout] 83 |             let end_Index_struct = bincode::deserialize::<IndexStruct>(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:101:14
[INFO] [stdout]     |
[INFO] [stdout] 101 | pub async fn Leader_replicas_sync(sync_message: &SyncMessage) -> Option<ReplicaseSyncData> {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `leader_replicas_sync`
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 3.45s
[INFO] running `Command { std: "docker" "inspect" "2a4bb6aaa56012b3510e552c53b53bf5daca6182d35de9c76a6f5d470a0e2ad5", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "2a4bb6aaa56012b3510e552c53b53bf5daca6182d35de9c76a6f5d470a0e2ad5", kill_on_drop: false }`
[INFO] [stdout] 2a4bb6aaa56012b3510e552c53b53bf5daca6182d35de9c76a6f5d470a0e2ad5
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:90999bfc7ae267e83380e433d8e61a7c072ca6729e92edbae886d3423b3a6f4c" "/opt/rustwide/cargo-home/bin/cargo" "+8de4c7234dd9b97c9d76b58671343fdbbc9a433e" "test" "--frozen" "--target" "x86_64-unknown-linux-musl", kill_on_drop: false }`
[INFO] [stdout] 1e15b5d3942f911bb84dddd8238e60a9f63f5dc5c6e046d882100c56558c97b8
[INFO] running `Command { std: "docker" "start" "-a" "1e15b5d3942f911bb84dddd8238e60a9f63f5dc5c6e046d882100c56558c97b8", 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] 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] warning: variant `string` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/MasterEntity.rs:6:5
[INFO] [stderr]   |
[INFO] [stderr] 6 |     string,
[INFO] [stderr]   |     ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `String`
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(non_camel_case_types)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variant `int` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/MasterEntity.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 |     int,
[INFO] [stderr]   |     ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Int`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `float` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/MasterEntity.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 |     float,
[INFO] [stderr]   |     ^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Float`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `boolean` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/MasterEntity.rs:9:5
[INFO] [stderr]   |
[INFO] [stderr] 9 |     boolean,
[INFO] [stderr]   |     ^^^^^^^ help: convert the identifier to upper camel case: `Boolean`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `long` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/MasterEntity.rs:10:5
[INFO] [stderr]    |
[INFO] [stderr] 10 |     long,
[INFO] [stderr]    |     ^^^^ help: convert the identifier to upper camel case: `Long`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `PRIMARY_KEY` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/MasterEntity.rs:15:5
[INFO] [stderr]    |
[INFO] [stderr] 15 |     PRIMARY_KEY,
[INFO] [stderr]    |     ^^^^^^^^^^^ help: convert the identifier to upper camel case: `PrimaryKey`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `NOT_NULL` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/MasterEntity.rs:16:5
[INFO] [stderr]    |
[INFO] [stderr] 16 |     NOT_NULL,
[INFO] [stderr]    |     ^^^^^^^^ help: convert the identifier to upper camel case: `NotNull`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `sql` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/MasterEntity.rs:98:5
[INFO] [stderr]    |
[INFO] [stderr] 98 |     sql(String),
[INFO] [stderr]    |     ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Sql`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `stream_read` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/MasterEntity.rs:99:5
[INFO] [stderr]    |
[INFO] [stderr] 99 |     stream_read(MasterStreamRead),
[INFO] [stderr]    |     ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `batch_insert` should have an upper camel case name
[INFO] [stderr]    --> entity_lib/src/entity/MasterEntity.rs:100:5
[INFO] [stderr]     |
[INFO] [stderr] 100 |     batch_insert(BatchInsert)
[INFO] [stderr]     |     ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `table` should have an upper camel case name
[INFO] [stderr]    --> entity_lib/src/entity/MasterEntity.rs:157:5
[INFO] [stderr]     |
[INFO] [stderr] 157 |     table(String),
[INFO] [stderr]     |     ^^^^^ help: convert the identifier to upper camel case: `Table`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `column` should have an upper camel case name
[INFO] [stderr]    --> entity_lib/src/entity/MasterEntity.rs:158:5
[INFO] [stderr]     |
[INFO] [stderr] 158 |     column(Vec<String>),
[INFO] [stderr]     |     ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Column`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `term` should have an upper camel case name
[INFO] [stderr]    --> entity_lib/src/entity/MasterEntity.rs:159:5
[INFO] [stderr]     |
[INFO] [stderr] 159 |     term(HashMap<String, serde_json::Value>),
[INFO] [stderr]     |     ^^^^ help: convert the identifier to upper camel case: `Term`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `gt` should have an upper camel case name
[INFO] [stderr]    --> entity_lib/src/entity/MasterEntity.rs:160:5
[INFO] [stderr]     |
[INFO] [stderr] 160 |     gt(HashMap<String, serde_json::Value>),
[INFO] [stderr]     |     ^^ help: convert the identifier to upper camel case: `Gt`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `lt` should have an upper camel case name
[INFO] [stderr]    --> entity_lib/src/entity/MasterEntity.rs:161:5
[INFO] [stderr]     |
[INFO] [stderr] 161 |     lt(HashMap<String, serde_json::Value>),
[INFO] [stderr]     |     ^^ help: convert the identifier to upper camel case: `Lt`
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `QueryItem`
[INFO] [stderr]  --> entity_lib/src/entity/SlaveEntity.rs:4:43
[INFO] [stderr]   |
[INFO] [stderr] 4 | use crate::entity::MasterEntity::{Insert, QueryItem, SlaveInsert};
[INFO] [stderr]   |                                           ^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variant `create` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:29:5
[INFO] [stderr]    |
[INFO] [stderr] 29 |     create(SlaveCreate),
[INFO] [stderr]    |     ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Create`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `query` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:30:5
[INFO] [stderr]    |
[INFO] [stderr] 30 |     query(QueryMessage),
[INFO] [stderr]    |     ^^^^^ help: convert the identifier to upper camel case: `Query`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `insert` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:31:5
[INFO] [stderr]    |
[INFO] [stderr] 31 |     insert(Insert),
[INFO] [stderr]    |     ^^^^^^ help: convert the identifier to upper camel case (notice the capitalization): `Insert`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `compress_table` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:32:5
[INFO] [stderr]    |
[INFO] [stderr] 32 |     compress_table(String),
[INFO] [stderr]    |     ^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CompressTable`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `stream_read` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:33:5
[INFO] [stderr]    |
[INFO] [stderr] 33 |     stream_read(StreamReadStruct),
[INFO] [stderr]    |     ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `batch_insert` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:34:5
[INFO] [stderr]    |
[INFO] [stderr] 34 |     batch_insert(SlaveInsert),
[INFO] [stderr]    |     ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `drop_table` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:35:5
[INFO] [stderr]    |
[INFO] [stderr] 35 |     drop_table(String),
[INFO] [stderr]    |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `follower_replicas_sync` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:36:5
[INFO] [stderr]    |
[INFO] [stderr] 36 |     follower_replicas_sync(ReplicasSyncStruct),
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `FollowerReplicasSync`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `leader_replicas_sync` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/SlaveEntity.rs:37:5
[INFO] [stderr]    |
[INFO] [stderr] 37 |     leader_replicas_sync(SyncMessage),
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `LeaderReplicasSync`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `CREATE_TABLE` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/DaqlEntity.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 |     CREATE_TABLE(TableStructure),
[INFO] [stderr]   |     ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CreateTable`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `SELECT_TABLE` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/DaqlEntity.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 |     SELECT_TABLE(QueryMessage),
[INFO] [stderr]   |     ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `SelectTable`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `ALTER_OROP` should have an upper camel case name
[INFO] [stderr]  --> entity_lib/src/entity/DaqlEntity.rs:9:5
[INFO] [stderr]   |
[INFO] [stderr] 9 |     ALTER_OROP((String, String)),
[INFO] [stderr]   |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `AlterOrop`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `ALTER_ADD` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/DaqlEntity.rs:10:5
[INFO] [stderr]    |
[INFO] [stderr] 10 |     ALTER_ADD((String, String, String, String, String)),
[INFO] [stderr]    |     ^^^^^^^^^ help: convert the identifier to upper camel case: `AlterAdd`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `SHOW_TABLE` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/DaqlEntity.rs:11:5
[INFO] [stderr]    |
[INFO] [stderr] 11 |     SHOW_TABLE(String),
[INFO] [stderr]    |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `ShowTable`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `COMPRESS_TABLE` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/DaqlEntity.rs:12:5
[INFO] [stderr]    |
[INFO] [stderr] 12 |     COMPRESS_TABLE(String),
[INFO] [stderr]    |     ^^^^^^^^^^^^^^ help: convert the identifier to upper camel case: `CompressTable`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `DROP_TABLE` should have an upper camel case name
[INFO] [stderr]   --> entity_lib/src/entity/DaqlEntity.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 13 |     DROP_TABLE(String),
[INFO] [stderr]    |     ^^^^^^^^^^ help: convert the identifier to upper camel case: `DropTable`
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Deserialize` and `Serialize`
[INFO] [stderr]  --> entity_lib/src/entity/mod.rs:7:13
[INFO] [stderr]   |
[INFO] [stderr] 7 | use serde::{Deserialize, Serialize};
[INFO] [stderr]   |             ^^^^^^^^^^^  ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `crate::entity::MasterEntity::Statement`
[INFO] [stderr]  --> entity_lib/src/entity/mod.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 | use crate::entity::MasterEntity::Statement;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: module `MasterEntity` should have a snake case name
[INFO] [stderr]  --> entity_lib/src/entity/mod.rs:1:9
[INFO] [stderr]   |
[INFO] [stderr] 1 | pub mod MasterEntity;
[INFO] [stderr]   |         ^^^^^^^^^^^^ help: convert the identifier to snake case: `master_entity`
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: module `SlaveEntity` should have a snake case name
[INFO] [stderr]  --> entity_lib/src/entity/mod.rs:2:9
[INFO] [stderr]   |
[INFO] [stderr] 2 | pub mod SlaveEntity;
[INFO] [stderr]   |         ^^^^^^^^^^^ help: convert the identifier to snake case: `slave_entity`
[INFO] [stderr] 
[INFO] [stderr] warning: module `Error` should have a snake case name
[INFO] [stderr]  --> entity_lib/src/entity/mod.rs:3:9
[INFO] [stderr]   |
[INFO] [stderr] 3 | pub mod Error;
[INFO] [stderr]   |         ^^^^^ help: convert the identifier to snake case: `error`
[INFO] [stderr] 
[INFO] [stderr] warning: module `DaqlEntity` should have a snake case name
[INFO] [stderr]  --> entity_lib/src/entity/mod.rs:4:9
[INFO] [stderr]   |
[INFO] [stderr] 4 | pub mod DaqlEntity;
[INFO] [stderr]   |         ^^^^^^^^^^ help: convert the identifier to snake case: `daql_entity`
[INFO] [stderr] 
[INFO] [stderr] warning: `entity_lib` (lib) generated 38 warnings (run `cargo fix --lib -p entity_lib` to apply 3 suggestions)
[INFO] [stderr] warning: `entity_lib` (lib test) generated 37 warnings (37 duplicates)
[INFO] [stderr] warning: unused import: `SlaveConfig`
[INFO] [stderr]  --> public_function/src/read_function.rs:1:13
[INFO] [stderr]   |
[INFO] [stderr] 1 | use crate::{SlaveConfig, SLAVE_CONFIG};
[INFO] [stderr]   |             ^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `uuid::Uuid`
[INFO] [stderr]   --> public_function/src/read_function.rs:11:5
[INFO] [stderr]    |
[INFO] [stderr] 11 | use uuid::Uuid;
[INFO] [stderr]    |     ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::iter::Map`
[INFO] [stderr]  --> public_function/src/lib.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 | use std::iter::Map;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::net::ToSocketAddrs`
[INFO] [stderr]  --> public_function/src/lib.rs:9:5
[INFO] [stderr]   |
[INFO] [stderr] 9 | use std::net::ToSocketAddrs;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> public_function/src/lib.rs:49:13
[INFO] [stderr]    |
[INFO] [stderr] 49 |         let mut data_path_index = self.data_path_index;
[INFO] [stderr]    |             ----^^^^^^^^^^^^^^^
[INFO] [stderr]    |             |
[INFO] [stderr]    |             help: remove this `mut`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> public_function/src/lib.rs:67:13
[INFO] [stderr]    |
[INFO] [stderr] 67 |         let mut master_slave_index = self.data_path_index;
[INFO] [stderr]    |             ----^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |             |
[INFO] [stderr]    |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> public_function/src/lib.rs:105:13
[INFO] [stderr]     |
[INFO] [stderr] 105 |         let mut path_index = self.data_path_index;
[INFO] [stderr]     |             ----^^^^^^^^^^
[INFO] [stderr]     |             |
[INFO] [stderr]     |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> public_function/src/lib.rs:163:13
[INFO] [stderr]     |
[INFO] [stderr] 163 |         let mut slave_config = SLAVE_CONFIG.lock().await;
[INFO] [stderr]     |             ----^^^^^^^^^^^^
[INFO] [stderr]     |             |
[INFO] [stderr]     |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `AsyncBufReadExt`
[INFO] [stderr]   --> public_function/src/lib.rs:12:17
[INFO] [stderr]    |
[INFO] [stderr] 12 | use tokio::io::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt};
[INFO] [stderr]    |                 ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: module `PosttingTcpStream` should have a snake case name
[INFO] [stderr]  --> public_function/src/lib.rs:1:9
[INFO] [stderr]   |
[INFO] [stderr] 1 | pub mod PosttingTcpStream;
[INFO] [stderr]   |         ^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `postting_tcp_stream`
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(non_snake_case)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: module `RandomNumber` should have a snake case name
[INFO] [stderr]  --> public_function/src/lib.rs:2:9
[INFO] [stderr]   |
[INFO] [stderr] 2 | pub mod RandomNumber;
[INFO] [stderr]   |         ^^^^^^^^^^^^ help: convert the identifier to snake case: `random_number`
[INFO] [stderr] 
[INFO] [stderr] warning: `public_function` (lib) generated 11 warnings (run `cargo fix --lib -p public_function` to apply 8 suggestions)
[INFO] [stderr] warning: `public_function` (lib test) generated 11 warnings (11 duplicates)
[INFO] [stderr] warning: variable `table_Key_words` should have a snake case name
[INFO] [stderr]   --> daql_analysis/src/lib.rs:28:13
[INFO] [stderr]    |
[INFO] [stderr] 28 |         let table_Key_words = sql[7..12].trim();
[INFO] [stderr]    |             ^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `table_key_words`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(non_snake_case)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable `col_type_Identification` should have a snake case name
[INFO] [stderr]   --> daql_analysis/src/analysis/create_daql.rs:16:9
[INFO] [stderr]    |
[INFO] [stderr] 16 |     let col_type_Identification = sql[left_parenthesis_index+1..right_parenthesis_index].trim();
[INFO] [stderr]    |         ^^^^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `col_type_identification`
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Decoder`
[INFO] [stderr]  --> slave/src/controls/compress_table.rs:5:17
[INFO] [stderr]   |
[INFO] [stderr] 5 | use snap::raw::{Decoder, Encoder};
[INFO] [stderr]   |                 ^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `AsyncReadExt`
[INFO] [stderr]  --> slave/src/controls/compress_table.rs:9:17
[INFO] [stderr]   |
[INFO] [stderr] 9 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt};
[INFO] [stderr]   |                 ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `public_function::SLAVE_CONFIG`
[INFO] [stderr]  --> slave/src/controls/query_table.rs:4:5
[INFO] [stderr]   |
[INFO] [stderr] 4 | use public_function::SLAVE_CONFIG;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `snap::raw::Decoder`
[INFO] [stderr]  --> slave/src/controls/query_table.rs:5:5
[INFO] [stderr]   |
[INFO] [stderr] 5 | use snap::raw::Decoder;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::fs::OpenOptions`
[INFO] [stderr]  --> slave/src/controls/query_table.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 | use tokio::fs::OpenOptions;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::io::AsyncReadExt`
[INFO] [stderr]  --> slave/src/controls/query_table.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 | use tokio::io::AsyncReadExt;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `public_function::read_function::get_slave_path`
[INFO] [stderr]  --> slave/src/controls/query_table.rs:9:5
[INFO] [stderr]   |
[INFO] [stderr] 9 | use public_function::read_function::get_slave_path;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `public_function::SLAVE_CONFIG`
[INFO] [stderr]  --> slave/src/controls/stream_read.rs:4:5
[INFO] [stderr]   |
[INFO] [stderr] 4 | use public_function::SLAVE_CONFIG;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::mem`
[INFO] [stderr]  --> slave/src/controls/stream_read.rs:5:5
[INFO] [stderr]   |
[INFO] [stderr] 5 | use std::mem;
[INFO] [stderr]   |     ^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary parentheses around assigned value
[INFO] [stderr]    --> slave/src/controls/stream_read.rs:100:21
[INFO] [stderr]     |
[INFO] [stderr] 100 |     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stderr]     |                     ^                               ^
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_parens)]` on by default
[INFO] [stderr] help: remove these parentheses
[INFO] [stderr]     |
[INFO] [stderr] 100 -     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stderr] 100 +     let mut right = index_file_len / INDEX_SIZE - 1;
[INFO] [stderr]     |
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary parentheses around assigned value
[INFO] [stderr]    --> slave/src/controls/stream_read.rs:114:20
[INFO] [stderr]     |
[INFO] [stderr] 114 |             left = (mid + 1);
[INFO] [stderr]     |                    ^       ^
[INFO] [stderr]     |
[INFO] [stderr] help: remove these parentheses
[INFO] [stderr]     |
[INFO] [stderr] 114 -             left = (mid + 1);
[INFO] [stderr] 114 +             left = mid + 1;
[INFO] [stderr]     |
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary parentheses around assigned value
[INFO] [stderr]    --> slave/src/controls/stream_read.rs:116:21
[INFO] [stderr]     |
[INFO] [stderr] 116 |             right = (mid - 1);
[INFO] [stderr]     |                     ^       ^
[INFO] [stderr]     |
[INFO] [stderr] help: remove these parentheses
[INFO] [stderr]     |
[INFO] [stderr] 116 -             right = (mid - 1);
[INFO] [stderr] 116 +             right = mid - 1;
[INFO] [stderr]     |
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `BatchInsert` and `Insert`
[INFO] [stderr]  --> slave/src/controls/batch_insert.rs:7:40
[INFO] [stderr]   |
[INFO] [stderr] 7 | use entity_lib::entity::MasterEntity::{BatchInsert, Insert, SlaveInsert};
[INFO] [stderr]   |                                        ^^^^^^^^^^^  ^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `SLAVE_CONFIG`
[INFO] [stderr]  --> slave/src/mechanism/replicas.rs:7:23
[INFO] [stderr]   |
[INFO] [stderr] 7 | use public_function::{SLAVE_CONFIG, get_partition_path};
[INFO] [stderr]   |                       ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary parentheses around assigned value
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:152:21
[INFO] [stderr]     |
[INFO] [stderr] 152 |     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stderr]     |                     ^                               ^
[INFO] [stderr]     |
[INFO] [stderr] help: remove these parentheses
[INFO] [stderr]     |
[INFO] [stderr] 152 -     let mut right = (index_file_len / INDEX_SIZE - 1);
[INFO] [stderr] 152 +     let mut right = index_file_len / INDEX_SIZE - 1;
[INFO] [stderr]     |
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary parentheses around assigned value
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:166:20
[INFO] [stderr]     |
[INFO] [stderr] 166 |             left = (mid + 1);
[INFO] [stderr]     |                    ^       ^
[INFO] [stderr]     |
[INFO] [stderr] help: remove these parentheses
[INFO] [stderr]     |
[INFO] [stderr] 166 -             left = (mid + 1);
[INFO] [stderr] 166 +             left = mid + 1;
[INFO] [stderr]     |
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary parentheses around assigned value
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:168:21
[INFO] [stderr]     |
[INFO] [stderr] 168 |             right = (mid - 1);
[INFO] [stderr]     |                     ^       ^
[INFO] [stderr]     |
[INFO] [stderr] help: remove these parentheses
[INFO] [stderr]     |
[INFO] [stderr] 168 -             right = (mid - 1);
[INFO] [stderr] 168 +             right = mid - 1;
[INFO] [stderr]     |
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `entity_lib::entity::Error::DataLakeError`
[INFO] [stderr]   --> slave/src/main.rs:10:5
[INFO] [stderr]    |
[INFO] [stderr] 10 | use entity_lib::entity::Error::DataLakeError;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `entity_lib::entity::MasterEntity::QueryItem`
[INFO] [stderr]   --> slave/src/main.rs:11:5
[INFO] [stderr]    |
[INFO] [stderr] 11 | use entity_lib::entity::MasterEntity::QueryItem;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `entity_lib::entity::SlaveEntity::SlaveMessage::drop_table`
[INFO] [stderr]   --> slave/src/main.rs:12:5
[INFO] [stderr]    |
[INFO] [stderr] 12 | use entity_lib::entity::SlaveEntity::SlaveMessage::drop_table;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `QueryMessage`
[INFO] [stderr]   --> slave/src/main.rs:13:39
[INFO] [stderr]    |
[INFO] [stderr] 13 | use entity_lib::entity::SlaveEntity::{QueryMessage, SlaveMessage};
[INFO] [stderr]    |                                       ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `error`
[INFO] [stderr]   --> slave/src/main.rs:14:11
[INFO] [stderr]    |
[INFO] [stderr] 14 | use log::{error, info};
[INFO] [stderr]    |           ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::path`
[INFO] [stderr]   --> slave/src/main.rs:16:5
[INFO] [stderr]    |
[INFO] [stderr] 16 | use std::path;
[INFO] [stderr]    |     ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::path::Path`
[INFO] [stderr]   --> slave/src/main.rs:17:5
[INFO] [stderr]    |
[INFO] [stderr] 17 | use std::path::Path;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::sync::Mutex`
[INFO] [stderr]   --> slave/src/main.rs:20:5
[INFO] [stderr]    |
[INFO] [stderr] 20 | use tokio::sync::Mutex;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `key`
[INFO] [stderr]   --> slave/src/controls/compress_table.rs:87:10
[INFO] [stderr]    |
[INFO] [stderr] 87 |     for (key, (position, len)) in res_map.into_iter() {
[INFO] [stderr]    |          ^^^ help: if this is intentional, prefix it with an underscore: `_key`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_variables)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/compress_table.rs:21:9
[INFO] [stderr]    |
[INFO] [stderr] 21 |     let mut log_files = public_function::get_list_filename(&table_name).await;
[INFO] [stderr]    |         ----^^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/insert_data.rs:52:17
[INFO] [stderr]    |
[INFO] [stderr] 52 |             let mut metadata_file = OpenOptions::new()
[INFO] [stderr]    |                 ----^^^^^^^^^^^^^
[INFO] [stderr]    |                 |
[INFO] [stderr]    |                 help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/insert_data.rs:59:17
[INFO] [stderr]    |
[INFO] [stderr] 59 |             let mut metadata_mmap = unsafe {MmapMut::map_mut(&metadata_file).unwrap()};
[INFO] [stderr]    |                 ----^^^^^^^^^^^^^
[INFO] [stderr]    |                 |
[INFO] [stderr]    |                 help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/insert_data.rs:78:17
[INFO] [stderr]    |
[INFO] [stderr] 78 |             let mut log_file = OpenOptions::new()
[INFO] [stderr]    |                 ----^^^^^^^^
[INFO] [stderr]    |                 |
[INFO] [stderr]    |                 help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/insert_data.rs:85:17
[INFO] [stderr]    |
[INFO] [stderr] 85 |             let mut index_file = OpenOptions::new()
[INFO] [stderr]    |                 ----^^^^^^^^^^
[INFO] [stderr]    |                 |
[INFO] [stderr]    |                 help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/controls/insert_data.rs:106:9
[INFO] [stderr]     |
[INFO] [stderr] 106 |     let mut metadata_mmap = &mut slave_cache_struct.metadata_mmap;
[INFO] [stderr]     |         ----^^^^^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `k`
[INFO] [stderr]   --> slave/src/controls/query_table.rs:51:16
[INFO] [stderr]    |
[INFO] [stderr] 51 |         .map(|(k, v)| {
[INFO] [stderr]    |                ^ help: if this is intentional, prefix it with an underscore: `_k`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/query_table.rs:25:9
[INFO] [stderr]    |
[INFO] [stderr] 25 |     let mut log_file = public_function::get_list_filename(&partition_name).await;
[INFO] [stderr]    |         ----^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/query_table.rs:29:9
[INFO] [stderr]    |
[INFO] [stderr] 29 |     let mut file_vec = log_file
[INFO] [stderr]    |         ----^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/stream_read.rs:17:9
[INFO] [stderr]    |
[INFO] [stderr] 17 |     let mut log_files = public_function::get_list_filename(&partition_name).await;
[INFO] [stderr]    |         ----^^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/stream_read.rs:42:9
[INFO] [stderr]    |
[INFO] [stderr] 42 |     let mut offset = streamreadstruct.offset;
[INFO] [stderr]    |         ----^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/stream_read.rs:43:9
[INFO] [stderr]    |
[INFO] [stderr] 43 |     let mut read_count = streamreadstruct.read_count;
[INFO] [stderr]    |         ----^^^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/stream_read.rs:64:13
[INFO] [stderr]    |
[INFO] [stderr] 64 |         let mut index_file = OpenOptions::new()
[INFO] [stderr]    |             ----^^^^^^^^^^
[INFO] [stderr]    |             |
[INFO] [stderr]    |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/stream_read.rs:91:9
[INFO] [stderr]    |
[INFO] [stderr] 91 |     let mut index_file = OpenOptions::new()
[INFO] [stderr]    |         ----^^^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/controls/stream_read.rs:135:13
[INFO] [stderr]     |
[INFO] [stderr] 135 |         let mut stream_data = load_data(index_path, &start_index, &end_index).await?;
[INFO] [stderr]     |             ----^^^^^^^^^^^
[INFO] [stderr]     |             |
[INFO] [stderr]     |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/controls/stream_read.rs:144:13
[INFO] [stderr]     |
[INFO] [stderr] 144 |         let mut stream_data = load_data(index_path, &start_index, &end_index).await?;
[INFO] [stderr]     |             ----^^^^^^^^^^^
[INFO] [stderr]     |             |
[INFO] [stderr]     |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/controls/stream_read.rs:164:9
[INFO] [stderr]     |
[INFO] [stderr] 164 |     let mut data_file = OpenOptions::new().read(true).open(data_path).await?;
[INFO] [stderr]     |         ----^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/batch_insert.rs:54:21
[INFO] [stderr]    |
[INFO] [stderr] 54 |                 let mut metadata_file = OpenOptions::new()
[INFO] [stderr]    |                     ----^^^^^^^^^^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/batch_insert.rs:60:21
[INFO] [stderr]    |
[INFO] [stderr] 60 |                 let mut metadata_mmap = unsafe {MmapMut::map_mut(&metadata_file)?};
[INFO] [stderr]    |                     ----^^^^^^^^^^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/batch_insert.rs:86:21
[INFO] [stderr]    |
[INFO] [stderr] 86 |                 let mut log_file = OpenOptions::new()
[INFO] [stderr]    |                     ----^^^^^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/controls/batch_insert.rs:93:21
[INFO] [stderr]    |
[INFO] [stderr] 93 |                 let mut index_file = OpenOptions::new()
[INFO] [stderr]    |                     ----^^^^^^^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/controls/batch_insert.rs:116:13
[INFO] [stderr]     |
[INFO] [stderr] 116 |         let mut metadata_mmap = &mut slave_cache_struct.metadata_mmap;
[INFO] [stderr]     |             ----^^^^^^^^^^^^^
[INFO] [stderr]     |             |
[INFO] [stderr]     |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/controls/batch_insert.rs:182:9
[INFO] [stderr]     |
[INFO] [stderr] 182 |     let mut metadata_mmap = &mut mutex_map.get_mut(&file_key).unwrap().metadata_mmap;
[INFO] [stderr]     |         ----^^^^^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> slave/src/mechanism/replicas.rs:23:9
[INFO] [stderr]    |
[INFO] [stderr] 23 |     let mut metadata_file = OpenOptions::new()
[INFO] [stderr]    |         ----^^^^^^^^^^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:105:9
[INFO] [stderr]     |
[INFO] [stderr] 105 |     let mut log_files = public_function::get_list_filename(&partition_code).await;
[INFO] [stderr]     |         ----^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:142:9
[INFO] [stderr]     |
[INFO] [stderr] 142 |     let mut index_file = OpenOptions::new()
[INFO] [stderr]     |         ----^^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:181:9
[INFO] [stderr]     |
[INFO] [stderr] 181 |     let mut snappy_file = OpenOptions::new()
[INFO] [stderr]     |         ----^^^^^^^^^^^
[INFO] [stderr]     |         |
[INFO] [stderr]     |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `AsyncReadExt`
[INFO] [stderr]  --> slave/src/controls/insert_data.rs:7:17
[INFO] [stderr]   |
[INFO] [stderr] 7 | use tokio::io::{AsyncReadExt, AsyncSeekExt, AsyncWriteExt};
[INFO] [stderr]   |                 ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary `unsafe` block
[INFO] [stderr]   --> slave/src/main.rs:54:9
[INFO] [stderr]    |
[INFO] [stderr] 54 |         unsafe {
[INFO] [stderr]    |         ^^^^^^ unnecessary `unsafe` block
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_unsafe)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` in tuple element 0 that must be used
[INFO] [stderr]   --> slave/src/main.rs:67:5
[INFO] [stderr]    |
[INFO] [stderr] 67 |     tokio::join!(slave);
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stderr]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stderr] 
[INFO] [stderr] warning: variable `tmpfile_offsetCode` should have a snake case name
[INFO] [stderr]   --> slave/src/controls/compress_table.rs:60:13
[INFO] [stderr]    |
[INFO] [stderr] 60 |     let mut tmpfile_offsetCode = HashMap::<String, i64>::new();
[INFO] [stderr]    |             ^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `tmpfile_offset_code`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(non_snake_case)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable `Index_struct` should have a snake case name
[INFO] [stderr]   --> slave/src/controls/stream_read.rs:75:13
[INFO] [stderr]    |
[INFO] [stderr] 75 |         let Index_struct = bincode::deserialize::<IndexStruct>(index_bytes)?;
[INFO] [stderr]    |             ^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `index_struct`
[INFO] [stderr] 
[INFO] [stderr] warning: variable `end_Index_struct` should have a snake case name
[INFO] [stderr]   --> slave/src/mechanism/replicas.rs:83:17
[INFO] [stderr]    |
[INFO] [stderr] 83 |             let end_Index_struct = bincode::deserialize::<IndexStruct>(return_end_offset)?;
[INFO] [stderr]    |                 ^^^^^^^^^^^^^^^^ help: convert the identifier to snake case (notice the capitalization): `end_index_struct`
[INFO] [stderr] 
[INFO] [stderr] warning: function `Leader_replicas_sync` should have a snake case name
[INFO] [stderr]    --> slave/src/mechanism/replicas.rs:101:14
[INFO] [stderr]     |
[INFO] [stderr] 101 | pub async fn Leader_replicas_sync(sync_message: &SyncMessage) -> Option<ReplicaseSyncData> {
[INFO] [stderr]     |              ^^^^^^^^^^^^^^^^^^^^ help: convert the identifier to snake case: `leader_replicas_sync`
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `TcpSocket`
[INFO] [stderr]  --> data-lake-client/src/controls/stream_read_logic.rs:7:18
[INFO] [stderr]   |
[INFO] [stderr] 7 | use tokio::net::{TcpSocket, TcpStream};
[INFO] [stderr]   |                  ^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `Statement`
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:1:40
[INFO] [stderr]   |
[INFO] [stderr] 1 | use entity_lib::entity::MasterEntity::{Statement, TableStructure};
[INFO] [stderr]   |                                        ^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `serde_json::json`
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:2:5
[INFO] [stderr]   |
[INFO] [stderr] 2 | use serde_json::json;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `AsyncReadExt` and `AsyncWriteExt`
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:3:17
[INFO] [stderr]   |
[INFO] [stderr] 3 | use tokio::io::{AsyncReadExt, AsyncWriteExt};
[INFO] [stderr]   |                 ^^^^^^^^^^^^  ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Create` and `MesterInsert`
[INFO] [stderr]  --> data-lake-client/src/entity/mod.rs:4:58
[INFO] [stderr]   |
[INFO] [stderr] 4 | use entity_lib::entity::MasterEntity::{BatchInsertTruth, Create, MasterStreamRead, MesterInsert};
[INFO] [stderr]   |                                                          ^^^^^^                    ^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variant `sql` should have an upper camel case name
[INFO] [stderr]   --> data-lake-client/src/entity/mod.rs:13:5
[INFO] [stderr]    |
[INFO] [stderr] 13 |     sql(String),
[INFO] [stderr]    |     ^^^ help: convert the identifier to upper camel case (notice the capitalization): `Sql`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(non_camel_case_types)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variant `stream_read` should have an upper camel case name
[INFO] [stderr]   --> data-lake-client/src/entity/mod.rs:14:5
[INFO] [stderr]    |
[INFO] [stderr] 14 |     stream_read(MasterStreamRead),
[INFO] [stderr]    |     ^^^^^^^^^^^ help: convert the identifier to upper camel case: `StreamRead`
[INFO] [stderr] 
[INFO] [stderr] warning: variant `batch_insert` should have an upper camel case name
[INFO] [stderr]   --> data-lake-client/src/entity/mod.rs:15:5
[INFO] [stderr]    |
[INFO] [stderr] 15 |     batch_insert(BatchInsertTruth),
[INFO] [stderr]    |     ^^^^^^^^^^^^ help: convert the identifier to upper camel case: `BatchInsert`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> data-lake-client/src/controls/stream_read_logic.rs:78:21
[INFO] [stderr]    |
[INFO] [stderr] 78 |                 let mut hash_map = &self.hash_map;
[INFO] [stderr]    |                     ----^^^^^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `bytes`
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 |     bytes: &[u8],
[INFO] [stderr]   |     ^^^^^ help: if this is intentional, prefix it with an underscore: `_bytes`
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_variables)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `bytes_len`
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 |     bytes_len: usize,
[INFO] [stderr]   |     ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_bytes_len`
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `stream`
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:9:5
[INFO] [stderr]   |
[INFO] [stderr] 9 |     stream: &mut TcpStream,
[INFO] [stderr]   |     ^^^^^^ help: if this is intentional, prefix it with an underscore: `_stream`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> data-lake-client/src/controls/stream_read_logic.rs:27:13
[INFO] [stderr]    |
[INFO] [stderr] 27 |         let mut hash_map = HashMap::<String, i64>::new();
[INFO] [stderr]    |             ----^^^^^^^^
[INFO] [stderr]    |             |
[INFO] [stderr]    |             help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unreachable pattern
[INFO] [stderr]    --> data-lake-client/src/main.rs:129:13
[INFO] [stderr]     |
[INFO] [stderr] 129 |             _ =>{
[INFO] [stderr]     |             ^ no value can reach this
[INFO] [stderr]     |
[INFO] [stderr] note: multiple earlier patterns match some of the same values
[INFO] [stderr]    --> data-lake-client/src/main.rs:129:13
[INFO] [stderr]     |
[INFO] [stderr] 51  |             ClientStatement::sql(sql) => {
[INFO] [stderr]     |             ------------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 85  |             ClientStatement::stream_read(stream_read) => {
[INFO] [stderr]     |             ----------------------------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 102 |             ClientStatement::batch_insert(batch_insert) => {
[INFO] [stderr]     |             ------------------------------------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 129 |             _ =>{
[INFO] [stderr]     |             ^ collectively making this unreachable
[INFO] [stderr]     = note: `#[warn(unreachable_patterns)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `sql`
[INFO] [stderr]   --> data-lake-client/src/main.rs:51:34
[INFO] [stderr]    |
[INFO] [stderr] 51 |             ClientStatement::sql(sql) => {
[INFO] [stderr]    |                                  ^^^ help: if this is intentional, prefix it with an underscore: `_sql`
[INFO] [stderr] 
[INFO] [stderr] warning: function `get_metadata` is never used
[INFO] [stderr]  --> data-lake-client/src/controls/metadata_logic.rs:6:14
[INFO] [stderr]   |
[INFO] [stderr] 6 | pub async fn get_metadata(
[INFO] [stderr]   |              ^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(dead_code)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: `daql_analysis` (lib) generated 2 warnings
[INFO] [stderr] warning: `slave` (bin "slave" test) generated 60 warnings (run `cargo fix --bin "slave" --tests` to apply 51 suggestions)
[INFO] [stderr] warning: `data-lake-client` (bin "data-lake-client" test) generated 16 warnings (run `cargo fix --bin "data-lake-client" --tests` to apply 7 suggestions)
[INFO] [stderr] warning: `daql_analysis` (lib test) generated 2 warnings (2 duplicates)
[INFO] [stderr] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stderr]  --> master/src/controls/compress_table.rs:4:40
[INFO] [stderr]   |
[INFO] [stderr] 4 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo};
[INFO] [stderr]   |                                        ^^^^  ^^^^^^^^^^^^^
[INFO] [stderr]   |
[INFO] [stderr]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stderr]  --> master/src/controls/create.rs:2:40
[INFO] [stderr]   |
[INFO] [stderr] 2 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo, TableStructure};
[INFO] [stderr]   |                                        ^^^^  ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::array`
[INFO] [stderr]  --> master/src/controls/stream_read.rs:7:5
[INFO] [stderr]   |
[INFO] [stderr] 7 | use std::array;
[INFO] [stderr]   |     ^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused imports: `Info` and `PartitionInfo`
[INFO] [stderr]  --> master/src/controls/batch_insert.rs:3:90
[INFO] [stderr]   |
[INFO] [stderr] 3 | use entity_lib::entity::MasterEntity::{BatchInsertTruth, ColumnConfigJudgment, DataType, Info, PartitionInfo, SlaveBatchData, SlaveInsert...
[INFO] [stderr]   |                                                                                          ^^^^  ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::net::TcpStream`
[INFO] [stderr]  --> master/src/controls/batch_insert.rs:9:5
[INFO] [stderr]   |
[INFO] [stderr] 9 | use tokio::net::TcpStream;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `public_function::MASTER_CONFIG`
[INFO] [stderr]  --> master/src/controls/alter.rs:3:5
[INFO] [stderr]   |
[INFO] [stderr] 3 | use public_function::MASTER_CONFIG;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::net::TcpStream`
[INFO] [stderr]  --> master/src/controls/alter.rs:6:5
[INFO] [stderr]   |
[INFO] [stderr] 6 | use tokio::net::TcpStream;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `PartitionInfo`
[INFO] [stderr]  --> master/src/mechanism/replicas.rs:1:46
[INFO] [stderr]   |
[INFO] [stderr] 1 | use entity_lib::entity::MasterEntity::{Info, PartitionInfo, TableStructure};
[INFO] [stderr]   |                                              ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `entity_lib::entity::Error::DataLakeError`
[INFO] [stderr]   --> master/src/main.rs:15:5
[INFO] [stderr]    |
[INFO] [stderr] 15 | use entity_lib::entity::Error::DataLakeError;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `error`
[INFO] [stderr]   --> master/src/main.rs:17:11
[INFO] [stderr]    |
[INFO] [stderr] 17 | use log::{error, info};
[INFO] [stderr]    |           ^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `write_error`
[INFO] [stderr]   --> master/src/main.rs:18:69
[INFO] [stderr]    |
[INFO] [stderr] 18 | use public_function::{MASTER_CONFIG, MasterConfig, load_properties, write_error};
[INFO] [stderr]    |                                                                     ^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `serde_json::json`
[INFO] [stderr]   --> master/src/main.rs:19:5
[INFO] [stderr]    |
[INFO] [stderr] 19 | use serde_json::json;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `std::any::Any`
[INFO] [stderr]   --> master/src/main.rs:21:5
[INFO] [stderr]    |
[INFO] [stderr] 21 | use std::any::Any;
[INFO] [stderr]    |     ^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::sync::Mutex`
[INFO] [stderr]   --> master/src/main.rs:25:5
[INFO] [stderr]    |
[INFO] [stderr] 25 | use tokio::sync::Mutex;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::sync::mpsc::Receiver`
[INFO] [stderr]   --> master/src/main.rs:26:5
[INFO] [stderr]    |
[INFO] [stderr] 26 | use tokio::sync::mpsc::Receiver;
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/controls/compress_table.rs:25:17
[INFO] [stderr]    |
[INFO] [stderr] 25 |             let mut message = SlaveMessage::compress_table(format!("{}-{}", table_name, key));
[INFO] [stderr]    |                 ----^^^^^^^
[INFO] [stderr]    |                 |
[INFO] [stderr]    |                 help: remove this `mut`
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_mut)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/controls/metadata.rs:12:9
[INFO] [stderr]    |
[INFO] [stderr] 12 |     let mut file = OpenOptions::new().read(true).open(&table_path).await?;
[INFO] [stderr]    |         ----^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/controls/metadata.rs:14:9
[INFO] [stderr]    |
[INFO] [stderr] 14 |     let mut mmap = unsafe { Mmap::map(&file)? };
[INFO] [stderr]    |         ----^^^^
[INFO] [stderr]    |         |
[INFO] [stderr]    |         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/controls/stream_read.rs:80:25
[INFO] [stderr]    |
[INFO] [stderr] 80 |                     let mut stream = TcpStream::connect(address).await?;
[INFO] [stderr]    |                         ----^^^^^^
[INFO] [stderr]    |                         |
[INFO] [stderr]    |                         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/controls/stream_read.rs:29:18
[INFO] [stderr]    |
[INFO] [stderr] 29 |     let (sender, mut receiver) = tokio::sync::mpsc::channel::<Option<Vec<u8>>>(10000);
[INFO] [stderr]    |                  ----^^^^^^^^
[INFO] [stderr]    |                  |
[INFO] [stderr]    |                  help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/controls/batch_insert.rs:52:21
[INFO] [stderr]    |
[INFO] [stderr] 52 |                 let mut stream = DataLakeTcpStream::connect(partition_info_vec).await?;
[INFO] [stderr]    |                     ----^^^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unused import: `tokio::io::AsyncWriteExt`
[INFO] [stderr]  --> master/src/controls/batch_insert.rs:8:5
[INFO] [stderr]   |
[INFO] [stderr] 8 | use tokio::io::AsyncWriteExt;
[INFO] [stderr]   |     ^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr] 
[INFO] [stderr] warning: unreachable pattern
[INFO] [stderr]    --> master/src/controls/batch_insert.rs:206:9
[INFO] [stderr]     |
[INFO] [stderr] 206 |         _ => {
[INFO] [stderr]     |         ^ no value can reach this
[INFO] [stderr]     |
[INFO] [stderr] note: multiple earlier patterns match some of the same values
[INFO] [stderr]    --> master/src/controls/batch_insert.rs:206:9
[INFO] [stderr]     |
[INFO] [stderr] 167 |         DataType::string => {
[INFO] [stderr]     |         ---------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 170 |         DataType::int => match col_value.parse::<i32>() {
[INFO] [stderr]     |         ------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 179 |         DataType::float => match col_value.parse::<f32>() {
[INFO] [stderr]     |         --------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 188 |         DataType::boolean => match col_value.parse::<bool>() {
[INFO] [stderr]     |         ----------------- matches some of the same values
[INFO] [stderr] ...
[INFO] [stderr] 206 |         _ => {
[INFO] [stderr]     |         ^ ...and 1 other patterns collectively make this unreachable
[INFO] [stderr]     = note: `#[warn(unreachable_patterns)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused variable: `e`
[INFO] [stderr]    --> master/src/controls/batch_insert.rs:172:17
[INFO] [stderr]     |
[INFO] [stderr] 172 |             Err(e) => {
[INFO] [stderr]     |                 ^ help: if this is intentional, prefix it with an underscore: `_e`
[INFO] [stderr]     |
[INFO] [stderr]     = note: `#[warn(unused_variables)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/mechanism/replicas.rs:40:25
[INFO] [stderr]    |
[INFO] [stderr] 40 |                     let mut mmap = unsafe { Mmap::map(&file) }.unwrap();
[INFO] [stderr]    |                         ----^^^^
[INFO] [stderr]    |                         |
[INFO] [stderr]    |                         help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: variable does not need to be mutable
[INFO] [stderr]   --> master/src/mechanism/replicas.rs:33:21
[INFO] [stderr]    |
[INFO] [stderr] 33 |                 let mut file = OpenOptions::new()
[INFO] [stderr]    |                     ----^^^^
[INFO] [stderr]    |                     |
[INFO] [stderr]    |                     help: remove this `mut`
[INFO] [stderr] 
[INFO] [stderr] warning: unnecessary `unsafe` block
[INFO] [stderr]   --> master/src/main.rs:57:9
[INFO] [stderr]    |
[INFO] [stderr] 57 |         unsafe {
[INFO] [stderr]    |         ^^^^^^ unnecessary `unsafe` block
[INFO] [stderr]    |
[INFO] [stderr]    = note: `#[warn(unused_unsafe)]` on by default
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` in tuple element 0 that must be used
[INFO] [stderr]   --> master/src/main.rs:68:5
[INFO] [stderr]    |
[INFO] [stderr] 68 |     tokio::join!(master_main, replicas_sync);
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]    = note: `#[warn(unused_must_use)]` on by default
[INFO] [stderr]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stderr] 
[INFO] [stderr] warning: unused `Result` in tuple element 1 that must be used
[INFO] [stderr]   --> master/src/main.rs:68:5
[INFO] [stderr]    |
[INFO] [stderr] 68 |     tokio::join!(master_main, replicas_sync);
[INFO] [stderr]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stderr]    |
[INFO] [stderr]    = note: this `Result` may be an `Err` variant, which should be handled
[INFO] [stderr]    = note: this warning originates in the macro `$crate::join` which comes from the expansion of the macro `tokio::join` (in Nightly builds, run with -Z macro-backtrace for more info)
[INFO] [stderr] 
[INFO] [stderr] warning: `master` (bin "master" test) generated 29 warnings (run `cargo fix --bin "master" --tests` to apply 23 suggestions)
[INFO] [stderr]     Finished `test` profile [unoptimized + debuginfo] target(s) in 0.11s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/x86_64-unknown-linux-musl/debug/deps/daql_analysis-671272f84e007706)
[INFO] [stdout] 
[INFO] [stderr]      Running unittests src/main.rs (/opt/rustwide/target/x86_64-unknown-linux-musl/debug/deps/data_lake_client-5349e61d3746a21e)
[INFO] [stdout] running 0 tests
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/x86_64-unknown-linux-musl/debug/deps/entity_lib-bbef41c22b61cab6)
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 0 tests
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] running 1 test
[INFO] [stdout] test entity::nnn ... FAILED
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- entity::nnn stdout ----
[INFO] [stdout] 
[INFO] [stdout] thread 'entity::nnn' panicked at entity_lib/src/entity/mod.rs:26:53:
[INFO] [stdout] called `Result::unwrap()` on an `Err` value: Error("unknown variant `insert`, expected one of `sql`, `stream_read`, `batch_insert`", line: 2, column: 13)
[INFO] [stdout] stack backtrace:
[INFO] [stdout]    0:     0x7f833f427682 - std::backtrace_rs::backtrace::libunwind::trace::h559918daaaf51ab7
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9
[INFO] [stdout]    1:     0x7f833f427682 - std::backtrace_rs::backtrace::trace_unsynchronized::hb04fbcf80d07af8b
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14
[INFO] [stdout]    2:     0x7f833f427682 - std::sys::backtrace::_print_fmt::h7c0bbbbfac0065d4
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/sys/backtrace.rs:66:9
[INFO] [stdout]    3:     0x7f833f427682 - <std::sys::backtrace::BacktraceLock::print::DisplayBacktrace as core::fmt::Display>::fmt::hb62c8ed31943daa5
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/sys/backtrace.rs:39:26
[INFO] [stdout]    4:     0x7f833f461913 - core::fmt::rt::Argument::fmt::he5eaa7dd607ed4c9
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/fmt/rt.rs:173:76
[INFO] [stdout]    5:     0x7f833f461913 - core::fmt::write::h375399f8cb90b45a
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/fmt/mod.rs:1460:25
[INFO] [stdout]    6:     0x7f833f4249b3 - std::io::default_write_fmt::hdc1b4dd565dd0099
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/io/mod.rs:639:11
[INFO] [stdout]    7:     0x7f833f4249b3 - std::io::Write::write_fmt::h29f6044e9bc43c23
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/io/mod.rs:1954:13
[INFO] [stdout]    8:     0x7f833f4274d2 - std::sys::backtrace::BacktraceLock::print::ha189c586374f916a
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/sys/backtrace.rs:42:9
[INFO] [stdout]    9:     0x7f833f428c5c - std::panicking::default_hook::{{closure}}::ha3a26c98ff210e12
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:300:27
[INFO] [stdout]   10:     0x7f833f428ab2 - std::panicking::default_hook::h8c8a86b4390ab794
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:324:9
[INFO] [stdout]   11:     0x7f833f3ee254 - <alloc::boxed::Box<F,A> as core::ops::function::Fn<Args>>::call::ha39ae63ed1e9a130
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/alloc/src/boxed.rs:1980:9
[INFO] [stdout]   12:     0x7f833f3ee254 - test::test_main_with_exit_callback::{{closure}}::h9df7c328ebe18c28
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/test/src/lib.rs:145:21
[INFO] [stdout]   13:     0x7f833f4296c3 - <alloc::boxed::Box<F,A> as core::ops::function::Fn<Args>>::call::h96b7201b552e9069
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/alloc/src/boxed.rs:1980:9
[INFO] [stdout]   14:     0x7f833f4296c3 - std::panicking::rust_panic_with_hook::hb3b66c2e80efa371
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:841:13
[INFO] [stdout]   15:     0x7f833f4293aa - std::panicking::begin_panic_handler::{{closure}}::h9c68d0f839e62070
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:706:13
[INFO] [stdout]   16:     0x7f833f427b89 - std::sys::backtrace::__rust_end_short_backtrace::h68d22ddde4a73ad6
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/sys/backtrace.rs:168:18
[INFO] [stdout]   17:     0x7f833f42903d - __rustc[f4ffc7196a45a630]::rust_begin_unwind
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:697:5
[INFO] [stdout]   18:     0x7f833f384480 - core::panicking::panic_fmt::h8cdd4c81eb9069aa
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/panicking.rs:75:14
[INFO] [stdout]   19:     0x7f833f3848e6 - core::result::unwrap_failed::h8476ffaa6db8205b
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/result.rs:1761:5
[INFO] [stdout]   20:     0x7f833f394082 - core::result::Result<T,E>::unwrap::hbf650d91dc861f86
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/result.rs:1167:23
[INFO] [stdout]   21:     0x7f833f394082 - entity_lib::entity::nnn::h33622c6e1197abb1
[INFO] [stdout]                                at /opt/rustwide/workdir/entity_lib/src/entity/mod.rs:26:53
[INFO] [stdout]   22:     0x7f833f393fd7 - entity_lib::entity::nnn::{{closure}}::h7eb28f98aee5fe9d
[INFO] [stdout]                                at /opt/rustwide/workdir/entity_lib/src/entity/mod.rs:13:13
[INFO] [stdout]   23:     0x7f833f38e216 - core::ops::function::FnOnce::call_once::hb5a68592b91d314a
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   24:     0x7f833f3f394b - core::ops::function::FnOnce::call_once::h9633dcf760ae81b2
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   25:     0x7f833f3f394b - test::__rust_begin_short_backtrace::h12ad5e04c8d7b4a5
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/test/src/lib.rs:648:18
[INFO] [stdout]   26:     0x7f833f3f2bbe - test::run_test_in_process::{{closure}}::he596b4fd3fa4893c
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/test/src/lib.rs:671:74
[INFO] [stdout]   27:     0x7f833f3f2bbe - <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once::hc746bc3fa75190e0
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/panic/unwind_safe.rs:272:9
[INFO] [stdout]   28:     0x7f833f3f2bbe - std::panicking::catch_unwind::do_call::hf4843906108d6299
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:589:40
[INFO] [stdout]   29:     0x7f833f3f2bbe - std::panicking::catch_unwind::h849d4e8b03577bb9
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:552:19
[INFO] [stdout]   30:     0x7f833f3f2bbe - std::panic::catch_unwind::ha1f814c1dec025d2
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panic.rs:359:14
[INFO] [stdout]   31:     0x7f833f3f2bbe - test::run_test_in_process::h542aad3fe61255e7
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/test/src/lib.rs:671:27
[INFO] [stdout]   32:     0x7f833f3f2bbe - test::run_test::{{closure}}::h612788d75908cb63
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/test/src/lib.rs:592:43
[INFO] [stdout]   33:     0x7f833f3b7a44 - test::run_test::{{closure}}::hbfeea3bcb7245123
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/test/src/lib.rs:622:41
[INFO] [stdout]   34:     0x7f833f3b7a44 - std::sys::backtrace::__rust_begin_short_backtrace::h72542b83b4f87d5b
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/sys/backtrace.rs:152:18
[INFO] [stdout]   35:     0x7f833f3bb23a - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::hff26a7547ea762c9
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/thread/mod.rs:559:17
[INFO] [stdout]   36:     0x7f833f3bb23a - <core::panic::unwind_safe::AssertUnwindSafe<F> as core::ops::function::FnOnce<()>>::call_once::hbee49bc759312884
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/panic/unwind_safe.rs:272:9
[INFO] [stdout]   37:     0x7f833f3bb23a - std::panicking::catch_unwind::do_call::h61de12ce5e04e28f
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:589:40
[INFO] [stdout]   38:     0x7f833f3bb23a - std::panicking::catch_unwind::h454dd49873d22e18
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panicking.rs:552:19
[INFO] [stdout]   39:     0x7f833f3bb23a - std::panic::catch_unwind::h5c15187324f8cebb
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/panic.rs:359:14
[INFO] [stdout]   40:     0x7f833f3bb23a - std::thread::Builder::spawn_unchecked_::{{closure}}::hbc9d9c7427673d42
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/thread/mod.rs:557:30
[INFO] [stdout]   41:     0x7f833f3bb23a - core::ops::function::FnOnce::call_once{{vtable.shim}}::hefd458a129ddca13
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/core/src/ops/function.rs:250:5
[INFO] [stdout]   42:     0x7f833f42c117 - <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once::h2d6e2e526b02c3da
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/alloc/src/boxed.rs:1966:9
[INFO] [stdout]   43:     0x7f833f42c117 - <alloc::boxed::Box<F,A> as core::ops::function::FnOnce<Args>>::call_once::h1aefced482b33c72
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/alloc/src/boxed.rs:1966:9
[INFO] [stdout]   44:     0x7f833f42c117 - std::sys::pal::unix::thread::Thread::new::thread_start::h7c9c6951b48f721d
[INFO] [stdout]                                at /rustc/8de4c7234dd9b97c9d76b58671343fdbbc9a433e/library/std/src/sys/pal/unix/thread.rs:97:17
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     entity::nnn
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.08s
[INFO] [stdout] 
[INFO] [stderr] error: test failed, to rerun pass `-p entity_lib --lib`
[INFO] running `Command { std: "docker" "inspect" "1e15b5d3942f911bb84dddd8238e60a9f63f5dc5c6e046d882100c56558c97b8", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "1e15b5d3942f911bb84dddd8238e60a9f63f5dc5c6e046d882100c56558c97b8", kill_on_drop: false }`
[INFO] [stdout] 1e15b5d3942f911bb84dddd8238e60a9f63f5dc5c6e046d882100c56558c97b8