Merge pull request #4433 from Xuanwo/opendal-v0.2.2

opendal: Bump to v0.2.2

common/contexts/Cargo.toml

@@ -10,4 +10,4 @@ test = false
 
 [dependencies]
 async-trait = "0.1.52"
-opendal = "0.2.0"
+opendal = "0.2.2"

common/exception/Cargo.toml

@@ -16,7 +16,7 @@ common-arrow = { path = "../arrow" }
 anyhow = "1.0.55"
 backtrace = "0.3.64"
 octocrab = "0.15.4"
-opendal = "0.2.0"
+opendal = "0.2.2"
 paste = "1.0.6"
 prost = "0.9.0"
 serde = { version = "1.0.136", features = ["derive"] }

common/io/Cargo.toml

@@ -22,7 +22,7 @@ bincode = { git = "https://github.com/datafuse-extras/bincode", rev = "fd3f9ff"
 # Crates.io dependencies
 bytes = "1.1.0"
 futures = "0.3.21"
-opendal = "0.2.0"
+opendal = "0.2.2"
 serde = { version = "1.0.136", features = ["derive"] }
 
 [dev-dependencies]

common/streams/Cargo.toml

@@ -33,4 +33,4 @@ tempfile = "3.3.0"
 tokio-stream = { version = "0.1.8", features = ["net"] }
 
 [dev-dependencies]
-opendal = "0.2.0"
+opendal = "0.2.2"

common/tracing/Cargo.toml

@@ -26,3 +26,4 @@ tracing-bunyan-formatter = "0.3.2"
 tracing-futures = { version = "0.2.5", features = ["futures-03"] }
 tracing-opentelemetry = "0.17.2"
 tracing-subscriber = { version = "0.3.9", features = ["env-filter"] }
+tracing-log = "0.1.2"

common/tracing/src/logging.rs

@@ -27,6 +27,7 @@ use tracing_appender::rolling::RollingFileAppender;
 use tracing_appender::rolling::Rotation;
 use tracing_bunyan_formatter::BunyanFormattingLayer;
 use tracing_bunyan_formatter::JsonStorageLayer;
+use tracing_log::LogTracer;
 use tracing_subscriber::fmt;
 use tracing_subscriber::fmt::format::Writer;
 use tracing_subscriber::fmt::time::FormatTime;
@@ -70,6 +71,9 @@ static GLOBAL_UT_LOG_GUARD: Lazy<Arc<Mutex<Option<Vec<WorkerGuard>>>>> =
 pub fn init_global_tracing(app_name: &str, dir: &str, level: &str) -> Vec<WorkerGuard> {
     let mut guards = vec![];
 
+    // Enable log compatible layer to convert log record to tracing span.
+    LogTracer::init().expect("log tracer must be valid");
+
     // Stdout layer.
     let (stdout_writer, stdout_guard) = tracing_appender::non_blocking(std::io::stdout());
     let stdout_logging_layer = Layer::new().with_writer(stdout_writer);

query/Cargo.toml

@@ -85,7 +85,7 @@ num = "0.4.0"
 num_cpus = "1.13.1"
 octocrab = "0.15.4"
 once_cell = "1.9.0"
-opendal = "0.2.0"
+opendal = "0.2.2"
 parquet-format-async-temp = "0.2.0"
 paste = "1.0.6"
 petgraph = "0.6.0"