diff --git a/src/meta-srv/src/procedure/create_table.rs b/src/meta-srv/src/procedure/create_table.rs
index c992d03a3a..c1f08d1085 100644
--- a/src/meta-srv/src/procedure/create_table.rs
+++ b/src/meta-srv/src/procedure/create_table.rs
@@ -224,10 +224,10 @@ impl CreateTableProcedure {
             }));
         }
 
-        let _ = join_all(joins)
+        let _r = join_all(joins)
             .await
             .into_iter()
-            .map(|e| e.context(error::JoinSnafu))
+            .map(|e| e.context(error::JoinSnafu).flatten())
             .collect::<Result<Vec<_>>>()?;
 
         self.creator.data.state = CreateTableState::CreateMetadata;
diff --git a/src/meta-srv/src/procedure/drop_table.rs b/src/meta-srv/src/procedure/drop_table.rs
index 76b2dffc3e..b54f491293 100644
--- a/src/meta-srv/src/procedure/drop_table.rs
+++ b/src/meta-srv/src/procedure/drop_table.rs
@@ -185,7 +185,7 @@ impl DropTableProcedure {
             }));
         }
 
-        let _ = join_all(joins)
+        let _r = join_all(joins)
             .await
             .into_iter()
             .map(|e| e.context(error::JoinSnafu).flatten())