chore: bump reqwest and hyper as much as possible

Cargo.toml

@@ -109,7 +109,7 @@ aws-smithy-http = "0.60"
 aws-smithy-runtime-api = "1"
 aws-smithy-runtime = "1"
 aws-smithy-types = { version = "1", default-features = false, features = [
-  "hyper-0-14-x",
+  "hyper-0-14-x", # required by aws sdk
 ] }
 aws-endpoint = "0.60"
 aws-types = "1"

src/common/Cargo.toml

@@ -75,7 +75,7 @@ prometheus = { version = "0.13" }
 prost = { workspace = true }
 rand = "0.8"
 regex = "1"
-reqwest = { version = "0.11", features = ["json"] }
+reqwest = { version = "0.12.2", features = ["json"] }
 risingwave-fields-derive = { path = "./fields-derive" }
 risingwave_common_estimate_size = { workspace = true }
 risingwave_common_metrics = { path = "./metrics" }

src/common/common_service/Cargo.toml

@@ -17,7 +17,7 @@ normal = ["workspace-hack"]
 [dependencies]
 async-trait = "0.1"
 futures = { version = "0.3", default-features = false, features = ["alloc"] }
-hyper = "0.14"
+hyper = "0.14" # required by tonic
 prometheus = { version = "0.13" }
 risingwave_common = { workspace = true }
 risingwave_pb = { workspace = true }

src/common/common_service/src/metrics_manager.rs

@@ -44,6 +44,7 @@ impl MetricsManager {
                         GLOBAL_METRICS_REGISTRY.deref().clone(),
                     ))
                     .service_fn(Self::metrics_service);
+                // TODO: use axum server
                 let serve_future =
                     hyper::Server::bind(&listen_socket_addr).serve(Shared::new(service));
                 if let Err(err) = serve_future.await {

src/common/metrics/Cargo.toml

@@ -20,7 +20,7 @@ clap = { version = "4", features = ["derive"] }
 easy-ext = "1"
 futures = { version = "0.3", default-features = false, features = ["alloc"] }
 http = "0.2"
-hyper = { version = "0.14", features = ["client"] }
+hyper = { version = "0.14", features = ["client"] } # used by tonic
 hytra = { workspace = true }
 itertools = "0.12"
 parking_lot = "0.12"

src/compute/Cargo.toml

@@ -23,7 +23,7 @@ either = "1"
 foyer = { workspace = true }
 futures = { version = "0.3", default-features = false, features = ["alloc"] }
 futures-async-stream = { workspace = true }
-hyper = "0.14"
+hyper = "0.14" # required by tonic
 itertools = "0.12"
 maplit = "1.0.2"
 pprof = { version = "0.13", features = ["flamegraph"] }

src/connector/Cargo.toml

@@ -66,7 +66,7 @@ hyper = { version = "0.14", features = [
     "http1",
     "http2",
     "stream",
-] }
+] } # required by clickhouse client
 hyper-tls = "0.5"
 icelake = { workspace = true }
 indexmap = { version = "1.9.3", features = ["serde"] }
@@ -111,7 +111,7 @@ rdkafka = { workspace = true, features = [
 ] }
 redis = { version = "0.25", features = ["aio", "tokio-comp", "async-std-comp"] }
 regex = "1.4"
-reqwest = { version = "0.11", features = ["json"] }
+reqwest = { version = "0.12.2", features = ["json"] }
 risingwave_common = { workspace = true }
 risingwave_common_estimate_size = { workspace = true }
 risingwave_jni_core = { workspace = true }

src/connector/src/sink/doris.rs

@@ -12,6 +12,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+// TODO: use hyper 1 or reqwest 0.12.2
+
 use std::collections::HashMap;
 use std::sync::Arc;
 

src/connector/src/sink/doris_starrocks_connector.rs

@@ -187,6 +187,7 @@ impl InserterInnerBuilder {
         })
     }
 
+    // TODO: use hyper 1 or reqwest 0.12.2
     fn build_request_and_client(
         &self,
         uri: String,

src/meta/Cargo.toml

@@ -34,7 +34,7 @@ fail = "0.5"
 function_name = "0.3.0"
 futures = { version = "0.3", default-features = false, features = ["alloc"] }
 hex = "0.4"
-hyper = "0.14"
+hyper = "0.14" # required by tonic
 itertools = "0.12"
 maplit = "1.0.2"
 memcomparable = { version = "0.2" }

src/object_store/Cargo.toml

@@ -22,14 +22,14 @@ crc32fast = "1"
 either = "1"
 fail = "0.5"
 futures = { version = "0.3", default-features = false, features = ["alloc"] }
-hyper = { version = "0.14", features = ["tcp", "client"] }
+hyper = { version = "0.14", features = ["tcp", "client"] } # required by aws sdk
 hyper-rustls = { version = "0.24.2", features = ["webpki-roots"] }
 hyper-tls = "0.5.0"
 itertools = "0.12"
 madsim = "0.2.22"
 opendal = "0.45.1"
 prometheus = { version = "0.13", features = ["process"] }
-reqwest = "0.11"
+reqwest = "0.11" # required by opendal
 risingwave_common = { workspace = true }
 rustls = "0.23.4"
 spin = "0.9"

src/risedevtool/Cargo.toml

@@ -26,7 +26,7 @@ itertools = "0.12"
 rdkafka = { workspace = true }
 redis = "0.25"
 regex = "1"
-reqwest = "0.11"
+reqwest = { version = "0.12.2", features = ["blocking"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 serde_with = "3"

src/rpc_client/Cargo.toml

@@ -20,7 +20,7 @@ easy-ext = "1"
 either = "1.10.0"
 futures = { version = "0.3", default-features = false, features = ["alloc"] }
 http = "0.2"
-hyper = "0.14"
+hyper = "0.14" # required by tonic
 itertools = "0.12.0"
 lru = { workspace = true }
 moka = { version = "0.12", features = ["future"] }

src/utils/pgwire/Cargo.toml

@@ -25,7 +25,7 @@ jsonwebtoken = "9"
 openssl = "0.10.60"
 panic-message = "0.3"
 parking_lot = "0.12"
-reqwest = { version = "0.11" }
+reqwest = "0.12.2"
 risingwave_common = { workspace = true }
 risingwave_sqlparser = { workspace = true }
 serde = { version = "1", features = ["derive"] }

src/workspace-hack/Cargo.toml

@@ -109,7 +109,8 @@ redis = { version = "0.25", features = ["async-std-comp", "tokio-comp"] }
 regex = { version = "1" }
 regex-automata = { version = "0.4", default-features = false, features = ["dfa", "hybrid", "meta", "nfa", "perf", "unicode"] }
 regex-syntax = { version = "0.8" }
-reqwest = { version = "0.11", features = ["blocking", "json", "rustls-tls"] }
+reqwest-5ef9efb8ec2df382 = { package = "reqwest", version = "0.12", features = ["blocking", "json"] }
+reqwest-a6292c17cd707f01 = { package = "reqwest", version = "0.11", default-features = false, features = ["blocking", "default-tls", "json", "rustls-tls"] }
 ring = { version = "0.16", features = ["std"] }
 rust_decimal = { version = "1", features = ["db-postgres", "maths"] }
 rustc-hash = { version = "1" }