diff --git a/Cargo.lock b/Cargo.lock
index 731685910a31..53f7f0f8103e 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -8793,9 +8793,9 @@ dependencies = [
 
 [[package]]
 name = "tokio-stream"
-version = "0.1.4"
+version = "0.1.10"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "c535f53c0cfa1acace62995a8994fc9cc1f12d202420da96ff306ee24d576469"
+checksum = "f6edf2d6bc038a43d31353570e27270603f4648d18f5ed10c0e179abe43255af"
 dependencies = [
  "futures-core",
  "pin-project-lite",
@@ -9077,7 +9077,7 @@ version = "1.6.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "1f559b464de2e2bdabcac6a210d12e9b5a5973c251e102c44c585c71d51bd78e"
 dependencies = [
- "cfg-if 0.1.10",
+ "cfg-if 1.0.0",
  "static_assertions",
 ]
 
diff --git a/diem-node/Cargo.toml b/diem-node/Cargo.toml
index 6545a5fd2361..19f42553533d 100644
--- a/diem-node/Cargo.toml
+++ b/diem-node/Cargo.toml
@@ -18,7 +18,7 @@ jemallocator = { version = "0.3.2", features = ["profiling", "unprefixed_malloc_
 rand = "0.8.3"
 structopt = "0.3.21"
 tokio = { version = "1.8.1", features = ["full"] }
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 
 backup-service = { path = "../storage/backup/backup-service" }
 consensus = { path = "../consensus" }
diff --git a/mempool/Cargo.toml b/mempool/Cargo.toml
index 53d715e6d13a..d976f6177ff2 100644
--- a/mempool/Cargo.toml
+++ b/mempool/Cargo.toml
@@ -21,7 +21,7 @@ rayon = "1.4.1"
 serde = { version = "1.0.124", default-features = false }
 thiserror = "1.0.24"
 tokio = { version = "1.8.1", features = ["full"] }
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 
 bounded-executor = { path = "../crates/bounded-executor" }
 channel = { path = "../crates/channel" }
diff --git a/network/Cargo.toml b/network/Cargo.toml
index 16f10c5de074..6779641bb2b9 100644
--- a/network/Cargo.toml
+++ b/network/Cargo.toml
@@ -29,7 +29,7 @@ serde_json = "1.0.64"
 thiserror = "1.0.24"
 tokio = { version = "1.8.1", features = ["full"] }
 tokio-retry = "0.3.0"
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 tokio-util = { version = "0.6.4", features = ["compat", "codec"] }
 
 bitvec = { path = "../crates/diem-bitvec", package = "diem-bitvec" }
diff --git a/state-sync/state-sync-v1/Cargo.toml b/state-sync/state-sync-v1/Cargo.toml
index d1944043c3f2..7bd137471763 100644
--- a/state-sync/state-sync-v1/Cargo.toml
+++ b/state-sync/state-sync-v1/Cargo.toml
@@ -21,7 +21,7 @@ rand = "0.8.3"
 serde = { version = "1.0.124", default-features = false }
 thiserror = "1.0.24"
 tokio = { version = "1.8.1", features = ["full"] }
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 
 consensus-notifications = { path = "../inter-component/consensus-notifications" }
 channel = { path = "../../crates/channel" }
diff --git a/state-sync/state-sync-v2/data-streaming-service/Cargo.toml b/state-sync/state-sync-v2/data-streaming-service/Cargo.toml
index c097f234f488..5ce0af4eafc0 100644
--- a/state-sync/state-sync-v2/data-streaming-service/Cargo.toml
+++ b/state-sync/state-sync-v2/data-streaming-service/Cargo.toml
@@ -17,7 +17,7 @@ once_cell = "1.7.2"
 serde = { version = "1.0.124", default-features = false }
 thiserror = "1.0.24"
 tokio = { version = "1.8.1", features = ["full"] }
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 
 channel = { path = "../../../crates/channel" }
 diem-config = { path = "../../../config" }
diff --git a/state-sync/state-sync-v2/state-sync-driver/Cargo.toml b/state-sync/state-sync-v2/state-sync-driver/Cargo.toml
index 4351881d59fa..8df8f82db9f7 100644
--- a/state-sync/state-sync-v2/state-sync-driver/Cargo.toml
+++ b/state-sync/state-sync-v2/state-sync-driver/Cargo.toml
@@ -14,7 +14,7 @@ futures = "0.3.12"
 serde = { version = "1.0.124", default-features = false }
 thiserror = "1.0.24"
 tokio = { version = "1.8.1", features = ["full"] }
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 
 consensus-notifications = { path = "../../inter-component/consensus-notifications" }
 data-streaming-service = { path = "../data-streaming-service" }
diff --git a/storage/backup/backup-cli/Cargo.toml b/storage/backup/backup-cli/Cargo.toml
index 0328825c5e45..ac772c7f3ddf 100644
--- a/storage/backup/backup-cli/Cargo.toml
+++ b/storage/backup/backup-cli/Cargo.toml
@@ -27,7 +27,7 @@ serde_json = "1.0.64"
 structopt = "0.3.21"
 toml = "0.5.8"
 tokio = { version = "1.8.1", features = ["full"] }
-tokio-stream = "0.1.4"
+tokio-stream = "0.1.10"
 tokio-util = { version = "0.6.4", features = ["compat"] }
 
 executor = { path = "../../../execution/executor" }