From c615fb2a93babc2bc7ce0dea399fb95d55c3dec3 Mon Sep 17 00:00:00 2001 From: Weny Xu Date: Tue, 11 Jul 2023 00:41:20 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20fix=20uncaught=20error=20=F0=9F=A5=B2=20?= =?UTF-8?q?(#1929)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit fix: fix uncaught error --- src/meta-srv/src/procedure/create_table.rs | 4 ++-- src/meta-srv/src/procedure/drop_table.rs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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::>>()?; 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())