diff --git a/src/meta-srv/src/bootstrap.rs b/src/meta-srv/src/bootstrap.rs
index 78c28b6fbf96..5a4cd1284227 100644
--- a/src/meta-srv/src/bootstrap.rs
+++ b/src/meta-srv/src/bootstrap.rs
@@ -288,8 +288,15 @@ async fn create_postgres_client(opts: &MetasrvOptions) -> Result<tokio_postgres:
     let postgres_url = opts.store_addrs.first().context(InvalidArgumentsSnafu {
         err_msg: "empty store addrs",
     })?;
-    let (client, _) = tokio_postgres::connect(postgres_url, NoTls)
+    let (client, connection) = tokio_postgres::connect(postgres_url, NoTls)
         .await
         .context(error::ConnectPostgresSnafu)?;
+
+    tokio::spawn(async move {
+        connection
+            .await
+            .context(error::PostgresExecutionSnafu)
+            .unwrap()
+    });
     Ok(client)
 }
diff --git a/src/meta-srv/src/election/postgres.rs b/src/meta-srv/src/election/postgres.rs
index ff368aeb09d6..9da2b1dd00dd 100644
--- a/src/meta-srv/src/election/postgres.rs
+++ b/src/meta-srv/src/election/postgres.rs
@@ -304,7 +304,7 @@ mod tests {
             }
             .fail();
         }
-        let (client, connection) = tokio_postgres::connect(&addr, NoTls)
+        let (client, connection) = tokio_postgres::connect(addr, NoTls)
             .await
             .context(PostgresExecutionSnafu)?;
         tokio::spawn(async move {