diff --git a/src/announcer/mod.rs b/src/announcer/mod.rs index 159fd18e..f0085e37 100644 --- a/src/announcer/mod.rs +++ b/src/announcer/mod.rs @@ -169,7 +169,7 @@ impl SchedulerAnnouncer { } }; - if let Err(err) = self.scheduler_client.init_announce_host(request).await { + if let Err(err) = self.scheduler_client.announce_host(request).await { error!("announce host to scheduler failed: {}", err); }; } diff --git a/src/grpc/scheduler.rs b/src/grpc/scheduler.rs index 56ed921c..a0c8eb58 100644 --- a/src/grpc/scheduler.rs +++ b/src/grpc/scheduler.rs @@ -313,7 +313,8 @@ impl SchedulerClient { && data .available_schedulers .iter() - .all(|available_scheduler| available_schedulers.contains(available_scheduler)) + .zip(available_schedulers.iter()) + .all(|(a, b)| a == b) { info!( "available schedulers is not changed: {:?}",