From 7987e08ca2885032572936c33cb18c333da6f98a Mon Sep 17 00:00:00 2001 From: JeremyHi Date: Fri, 4 Aug 2023 09:38:17 +0800 Subject: [PATCH] chore: typo (#2092) --- src/datanode/src/instance.rs | 6 +++--- src/meta-srv/src/metasrv.rs | 4 ++-- src/meta-srv/src/metasrv/builder.rs | 2 +- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/datanode/src/instance.rs b/src/datanode/src/instance.rs index 3f2def6626..4a8f0f5f97 100644 --- a/src/datanode/src/instance.rs +++ b/src/datanode/src/instance.rs @@ -83,7 +83,7 @@ pub struct Instance { pub(crate) catalog_manager: CatalogManagerRef, pub(crate) table_id_provider: Option, procedure_manager: ProcedureManagerRef, - greptimedb_telemerty_task: Arc, + greptimedb_telemetry_task: Arc, } pub type InstanceRef = Arc; @@ -305,7 +305,7 @@ impl Instance { catalog_manager: catalog_manager.clone(), table_id_provider, procedure_manager, - greptimedb_telemerty_task: get_greptimedb_telemetry_task(&opts.mode).await, + greptimedb_telemetry_task: get_greptimedb_telemetry_task(&opts.mode).await, }); let heartbeat_task = Instance::build_heartbeat_task( @@ -335,7 +335,7 @@ impl Instance { .start() .context(StartProcedureManagerSnafu)?; let _ = self - .greptimedb_telemerty_task + .greptimedb_telemetry_task .start(common_runtime::bg_runtime()) .map_err(|e| { debug!("Failed to start greptimedb telemetry task: {}", e); diff --git a/src/meta-srv/src/metasrv.rs b/src/meta-srv/src/metasrv.rs index 0bf5427ff1..4097887f00 100644 --- a/src/meta-srv/src/metasrv.rs +++ b/src/meta-srv/src/metasrv.rs @@ -177,7 +177,7 @@ pub struct MetaSrv { mailbox: MailboxRef, ddl_manager: DdlManagerRef, table_metadata_manager: TableMetadataManagerRef, - greptimedb_telemerty_task: Arc, + greptimedb_telemetry_task: Arc, pubsub: Option<(PublishRef, SubscribeManagerRef)>, } @@ -200,7 +200,7 @@ impl MetaSrv { let leader_cached_kv_store = self.leader_cached_kv_store.clone(); let subscribe_manager = self.subscribe_manager().cloned(); let mut rx = election.subscribe_leader_change(); - let task_handler = self.greptimedb_telemerty_task.clone(); + let task_handler = self.greptimedb_telemetry_task.clone(); let _handle = common_runtime::spawn_bg(async move { loop { match rx.recv().await { diff --git a/src/meta-srv/src/metasrv/builder.rs b/src/meta-srv/src/metasrv/builder.rs index de041ab700..a662903007 100644 --- a/src/meta-srv/src/metasrv/builder.rs +++ b/src/meta-srv/src/metasrv/builder.rs @@ -251,7 +251,7 @@ impl MetaSrvBuilder { mailbox, ddl_manager, table_metadata_manager, - greptimedb_telemerty_task: get_greptimedb_telemetry_task(meta_peer_client).await, + greptimedb_telemetry_task: get_greptimedb_telemetry_task(meta_peer_client).await, pubsub, }) }