diff --git a/Cargo.lock b/Cargo.lock
index 545c3615ab46..dcaf114663d1 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -7022,9 +7022,9 @@ checksum = "cda74da7e1a664f795bb1f8a87ec406fb89a02522cf6e50620d016add6dbbf5c"
 
 [[package]]
 name = "tokio"
-version = "1.0.2"
+version = "1.3.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0ca04cec6ff2474c638057b65798f60ac183e5e79d3448bb7163d36a39cff6ec"
+checksum = "8d56477f6ed99e10225f38f9f75f872f29b8b8bd8c0b946f63345bb144e9eeda"
 dependencies = [
  "autocfg 1.0.1",
  "bytes 1.0.1",
@@ -7052,9 +7052,9 @@ dependencies = [
 
 [[package]]
 name = "tokio-macros"
-version = "1.0.0"
+version = "1.1.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "42517d2975ca3114b22a16192634e8241dc5cc1f130be194645970cc1c371494"
+checksum = "caf7b11a536f46a809a8a9f0bb4237020f70ecbf115b842360afb127ea2fda57"
 dependencies = [
  "proc-macro2 1.0.24",
  "quote 1.0.8",
@@ -7095,9 +7095,9 @@ dependencies = [
 
 [[package]]
 name = "tokio-stream"
-version = "0.1.1"
+version = "0.1.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "e4cdeb73537e63f98adcd73138af75e3f368ccaecffaa29d7eb61b9f5a440457"
+checksum = "c535f53c0cfa1acace62995a8994fc9cc1f12d202420da96ff306ee24d576469"
 dependencies = [
  "futures-core",
  "pin-project-lite",
diff --git a/diem-node/Cargo.toml b/diem-node/Cargo.toml
index a697b7c93e30..0ab9f6052095 100644
--- a/diem-node/Cargo.toml
+++ b/diem-node/Cargo.toml
@@ -15,7 +15,7 @@ futures = "0.3.12"
 jemallocator = { version = "0.3.2", features = ["profiling", "unprefixed_malloc_on_supported_platforms"] }
 structopt = "0.3.21"
 tokio = { version = "1.0.2", features = ["full"] }
-tokio-stream = "0.1.1"
+tokio-stream = "0.1.4"
 
 backup-service = { path = "../storage/backup/backup-service", version = "0.1.0" }
 consensus = { path = "../consensus", version = "0.1.0" }
diff --git a/mempool/Cargo.toml b/mempool/Cargo.toml
index 45f5a761f584..ba8affca6216 100644
--- a/mempool/Cargo.toml
+++ b/mempool/Cargo.toml
@@ -19,7 +19,7 @@ proptest = { version = "0.10.1", optional = true }
 rayon = "1.4.1"
 serde = { version = "1.0.120", default-features = false }
 tokio = { version = "1.0.2", features = ["full"] }
-tokio-stream = "0.1.1"
+tokio-stream = "0.1.4"
 
 bounded-executor = { path = "../common/bounded-executor", version = "0.1.0" }
 channel = { path = "../common/channel", version = "0.1.0" }
diff --git a/network/Cargo.toml b/network/Cargo.toml
index c8774db9f02e..4204866df5e6 100644
--- a/network/Cargo.toml
+++ b/network/Cargo.toml
@@ -26,7 +26,7 @@ serde_bytes = "0.11.5"
 thiserror = "1.0.23"
 tokio = { version = "1.0.2", features = ["full"] }
 tokio-retry = "0.2.0"
-tokio-stream = "0.1.1"
+tokio-stream = "0.1.4"
 tokio-util = { version = "0.6.0", features = ["compat", "codec"] }
 
 bitvec = { path = "../common/bitvec", version = "0.1.0", package = "diem-bitvec" }
diff --git a/state-synchronizer/Cargo.toml b/state-synchronizer/Cargo.toml
index ae83642c6993..ae7f99ca9cde 100644
--- a/state-synchronizer/Cargo.toml
+++ b/state-synchronizer/Cargo.toml
@@ -20,7 +20,7 @@ proptest = { version = "0.10.1", optional = true }
 rand = "0.7.3"
 serde = { version = "1.0.120", default-features = false }
 tokio = { version = "1.0.2", features = ["full"] }
-tokio-stream = "0.1.1"
+tokio-stream = "0.1.4"
 
 channel = { path = "../common/channel", version = "0.1.0" }
 diem-config = { path = "../config", version = "0.1.0" }
diff --git a/storage/backup/backup-cli/Cargo.toml b/storage/backup/backup-cli/Cargo.toml
index 5bca6c773c39..bc081c1a8e00 100644
--- a/storage/backup/backup-cli/Cargo.toml
+++ b/storage/backup/backup-cli/Cargo.toml
@@ -27,7 +27,7 @@ serde_json = "1.0.61"
 structopt = "0.3.21"
 toml = "0.5.8"
 tokio = { version = "1.0.2", features = ["full"] }
-tokio-stream = "0.1.1"
+tokio-stream = "0.1.4"
 tokio-util = { version = "0.6.0", features = ["compat"] }
 
 executor = { path = "../../../execution/executor", version = "0.1.0" }