Cleanup overlapping rust dependencies and bump up some to latest version (#2377)

Author: siyuan0322

interactive_engine/executor/assembly/groot/Cargo.toml

@@ -16,7 +16,7 @@ pegasus_server = { path = "../../engine/pegasus/server" }
 runtime_integration =  { path = "../../ir/integrated" }
 log = "0.4"
 log4rs = "1.2"
-tokio = { version = "1.0", features = ["macros", "sync"] }
+tokio = { version = "1.24", features = ["macros", "sync"] }
 
 [features]
 column_filter_push_down = ["runtime_integration/column_filter_push_down"]

interactive_engine/executor/assembly/v6d/Cargo.toml

@@ -8,13 +8,13 @@ edition = "2018"
 [dependencies]
 log = "0.4"
 log4rs = "1.2"
-serde = "1.0.72"
-serde_derive = "1.0.72"
-serde_json = "1.0.3"
-structopt = "0.2"
-lru_time_cache = "0.8.0"
+serde = "1.0"
+serde_derive = "1.0"
+serde_json = "1.0"
+structopt = "0.3"
+lru_time_cache = "0.11"
 dotproperties = "0.1.0"
-tokio = { version = "1.0", features = ["macros", "sync"] }
+tokio = { version = "1.24", features = ["macros", "sync"] }
 
 global_query = { path = "../../store/global_query" , features = ["with_v6d"] }
 pegasus = { path = "../../engine/pegasus/pegasus", package = "pegasus" }

interactive_engine/executor/common/dyn_type/Cargo.toml

@@ -5,6 +5,6 @@ edition = "2018"
 
 [dependencies]
 dyn-clonable = "0.9.0"
-itertools = "0.9"
+itertools = "0.10"
 lazy_static = "1.3.0"
 pegasus_common = { path = "../../engine/pegasus/common" }

interactive_engine/executor/engine/pegasus/benchmark/Cargo.toml

@@ -11,15 +11,15 @@ edition = "2018"
 pegasus_graph = { path = "../graph" }
 pegasus = { path = "../pegasus" }
 pegasus_common = { path = "../common" }
-tonic = { version = "0.5", features = ["default", "compression"] }
-prost = "0.8"
-tokio = { version = "1.0", features = ["macros", "sync", "rt-multi-thread"] }
+tonic = { version = "0.8", features = ["default", "compression"] }
+prost = "0.11"
+tokio = { version = "1.24", features = ["macros", "sync", "rt-multi-thread"] }
 structopt = "0.3"
-futures = "0.3.19"
+futures = "0.3"
 log = "0.4"
 
 [build-dependencies]
-tonic-build = { version = "0.5", features = ["default", "compression"] }
+tonic-build = { version = "0.8", features = ["default", "compression"] }
 
 [features]
 default = []

interactive_engine/executor/engine/pegasus/clients/rust/client/Cargo.toml

@@ -8,7 +8,7 @@ edition = "2018"
 [dependencies]
 pegasus_server = { path = "../../../server" }
 pegasus = { path = "../../../pegasus" }
-tonic = "0.6"
-prost = "0.9"
-tokio = { version = "1.0", features = ["macros", "sync", "rt-multi-thread"] }
-tokio-stream = { version = "0.1.3", features = ["net"] }
+tonic = "0.8"
+prost = "0.11"
+tokio = { version = "1.24", features = ["macros", "sync", "rt-multi-thread"] }
+tokio-stream = { version = "0.1.11", features = ["net"] }

interactive_engine/executor/engine/pegasus/common/Cargo.toml

@@ -6,24 +6,24 @@ edition = "2018"
 
 [dependencies]
 log = "0.4"
-crossbeam-channel = "0.4.4"
+crossbeam-channel = "0.5.6"
 crossbeam-queue = "0.3"
-crossbeam-deque = "0.7"
-crossbeam-utils = "0.8.7"
-backtrace = "0.3.45"
+crossbeam-deque = "0.8"
+crossbeam-utils = "0.8.14"
+backtrace = "0.3.67"
 log4rs = { version = "1.2", optional = true }
 bitflags = "1.2.1"
-bytes = "0.6"
-byteorder = "1.3.0"
-serde = { version = "1.0.72", optional = true }
-env_logger = { version = "0.6" , optional = true }
-time = { version = "0.1", optional = true }
+bytes = "1.3"
+byteorder = "1.4.3"
+serde = { version = "1.0", optional = true }
+env_logger = { version = "0.10" , optional = true }
 smallvec = "1.6"
-rand = "0.8.3"
+rand = "0.8.5"
+time = { version = "0.3", optional = true, features = [ "formatting" ]}
 
 [dev-dependencies]
 bincode = "1.0.1"
-rand = "0.8"
+rand = "0.8.5"
 
 [features]
 env_log = ["env_logger", "time"]

interactive_engine/executor/engine/pegasus/common/src/logs.rs

@@ -82,14 +82,14 @@ mod log_4_rs {
 #[cfg(feature = "env_logger")]
 mod log_env {
     use std::io::Write;
-
     use env_logger::fmt::Color;
     use log::Level;
+    use time::format_description;
+    use time::OffsetDateTime;
 
     pub fn init_log() {
         env_logger::Builder::from_default_env()
             .format(|buf, record| {
-                let t = time::now();
                 let mut level_style = buf.style();
                 match record.level() {
                     Level::Error => {
@@ -112,12 +112,13 @@ mod log_env {
                         level_style.set_color(Color::Blue);
                     }
                 };
-
+                let dt = OffsetDateTime::now_utc();
+                let dt_fmt = format_description::parse("[year]-[month]-[day] [hour]:[minute]:[second]").unwrap();
                 writeln!(
                     buf,
                     "{},{:03} {}\t[{}] [{}:{}] {}",
-                    time::strftime("%Y-%m-%d %H:%M:%S", &t).unwrap(),
-                    t.tm_nsec / 1000_000,
+                    dt.format(&dt_fmt).unwrap(),
+                    dt.millisecond(),
                     level_style.value(record.level()),
                     ::std::thread::current()
                         .name()

interactive_engine/executor/engine/pegasus/executor/Cargo.toml

@@ -8,8 +8,8 @@ edition = "2018"
 log = "0.4"
 lazy_static = "1.3.0"
 crossbeam-queue = "0.3"
-crossbeam-channel = "0.4.4"
-crossbeam-utils = "0.8.7"
+crossbeam-channel = "0.5.6"
+crossbeam-utils = "0.8.14"
 num_cpus = "1.11"
 pegasus_common = { path = "../common" }
 pegasus_memory = { path = "../memory" }

interactive_engine/executor/engine/pegasus/graph/Cargo.toml

@@ -5,11 +5,11 @@ authors = ["chenqiang.mcq <chenqiang.mcq@alibaba-inc.com>"]
 edition = "2018"
 
 [dependencies]
-byteorder = "1.3.0"
+byteorder = "1.4.3"
 nohash-hasher = "0.2.0"
-crossbeam-utils = "0.8.7"
+crossbeam-utils = "0.8.14"
 #snap = "1"
-rand = "0.8.3"
+rand = "0.8.5"
 memmap = "0.7.0"
 ahash = "0.7.2"
 lazy_static = "1.3.0"

interactive_engine/executor/engine/pegasus/memory/Cargo.toml

@@ -10,5 +10,5 @@ mem = []
 
 [dependencies]
 #log = "0.4"
-crossbeam-utils = "0.8.7"
+crossbeam-utils = "0.8.14"
 lazy_static = "1.3.0"