diff --git a/src/query/service/src/clusters/cluster.rs b/src/query/service/src/clusters/cluster.rs
index c6626ba3962ba..7133d5a9a1ffa 100644
--- a/src/query/service/src/clusters/cluster.rs
+++ b/src/query/service/src/clusters/cluster.rs
@@ -136,7 +136,6 @@ impl ClusterHelper for Cluster {
         }
 
         let mut response = HashMap::with_capacity(message.len());
-        // let mut futures = Vec::with_capacity(message.len());
         for (id, message) in message {
             let node = get_node(&self.nodes, &id)?;
 
@@ -150,26 +149,9 @@ impl ClusterHelper for Cluster {
                 conn.do_action::<_, Res>(path, node_secret, message, timeout)
                     .await?,
             );
-            // Ok::<_, ErrorCode>((
-            //     id,
-            //     conn.do_action::<_, Res>(path, node_secret, message, timeout)
-            //         .await?,
-            // ))
-            //
-            // futures.push({
-            //     let config = GlobalConfig::instance();
-            //     let flight_address = node.flight_address.clone();
-            //     let node_secret = node.secret.clone();
-            //
-            //     async move {
-            //
-            //     }
-            // });
         }
 
         Ok(response)
-        // let responses: Vec<(String, Res)> = futures::future::try_join_all(futures).await?;
-        // Ok(responses.into_iter().collect::<HashMap<String, Res>>())
     }
 }