From 32a1fac2b48d38ead094ed852060981b563f3893 Mon Sep 17 00:00:00 2001 From: August Date: Thu, 7 Jul 2022 16:42:50 +0800 Subject: [PATCH] fix: fix heartbeat req field and meta client impl --- proto/meta.proto | 1 - src/rpc_client/src/meta_client.rs | 5 +---- 2 files changed, 1 insertion(+), 5 deletions(-) diff --git a/proto/meta.proto b/proto/meta.proto index e9bdf9c15a4e2..f4608debbc24a 100644 --- a/proto/meta.proto +++ b/proto/meta.proto @@ -12,7 +12,6 @@ option optimize_for = SPEED; message HeartbeatRequest { uint32 node_id = 1; - common.WorkerType worker_type = 2; } message HeartbeatResponse { diff --git a/src/rpc_client/src/meta_client.rs b/src/rpc_client/src/meta_client.rs index c3c396c5afcfe..baa7728c147f1 100644 --- a/src/rpc_client/src/meta_client.rs +++ b/src/rpc_client/src/meta_client.rs @@ -114,10 +114,7 @@ impl MetaClient { /// Send heartbeat signal to meta service. pub async fn send_heartbeat(&self, node_id: u32) -> Result<()> { - let request = HeartbeatRequest { - node_id, - worker_type: WorkerType::ComputeNode as i32, - }; + let request = HeartbeatRequest { node_id }; self.inner.heartbeat(request).await?; Ok(()) }