fix: leader checker (#510)

* fix: leader checker bug

* chore: rm  of test_dist_table_scan
This commit is contained in:
Jiachun Feng
2022-11-15 14:52:47 +08:00
committed by GitHub
parent 934c18b914
commit a0144ffa61
2 changed files with 4 additions and 8 deletions

View File

@@ -655,8 +655,6 @@ mod test {
}
#[tokio::test(flavor = "multi_thread")]
// FIXME(LFC): Remove ignore.
#[ignore]
async fn test_dist_table_scan() {
common_telemetry::init_default_ut_logging();
let table = Arc::new(new_dist_table().await);

View File

@@ -20,13 +20,11 @@ impl HeartbeatHandler for CheckLeaderHandler {
if election.is_leader() {
return Ok(());
}
if let Some(header) = &mut acc.header {
header.error = Some(Error::is_not_leader());
ctx.set_skip_all();
}
}
if let Some(header) = &mut acc.header {
header.error = Some(Error::is_not_leader());
ctx.set_skip_all();
}
Ok(())
}
}