Skip to content

Commit

Permalink
chore: fix typos linted by cSpell (#14306)
Browse files Browse the repository at this point in the history
Signed-off-by: TennyZhuang <[email protected]>
Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
  • Loading branch information
TennyZhuang and github-actions[bot] authored Jan 2, 2024
1 parent 56ce4e2 commit 4eacb34
Show file tree
Hide file tree
Showing 7 changed files with 14 additions and 14 deletions.
6 changes: 3 additions & 3 deletions src/batch/src/executor/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ pub use update::*;
pub use utils::*;
pub use values::*;

use self::test_utils::{BlockExecutorBuidler, BusyLoopExecutorBuidler};
use self::test_utils::{BlockExecutorBuilder, BusyLoopExecutorBuilder};
use crate::error::Result;
use crate::executor::sys_row_seq_scan::SysRowSeqScanExecutorBuilder;
use crate::task::{BatchTaskContext, ShutdownToken, TaskId};
Expand Down Expand Up @@ -235,8 +235,8 @@ impl<'a, C: BatchTaskContext> ExecutorBuilder<'a, C> {
NodeBody::SortOverWindow => SortOverWindowExecutor,
NodeBody::MaxOneRow => MaxOneRowExecutor,
// Follow NodeBody only used for test
NodeBody::BlockExecutor => BlockExecutorBuidler,
NodeBody::BusyLoopExecutor => BusyLoopExecutorBuidler,
NodeBody::BlockExecutor => BlockExecutorBuilder,
NodeBody::BusyLoopExecutor => BusyLoopExecutorBuilder,
}
.await?;

Expand Down
8 changes: 4 additions & 4 deletions src/batch/src/executor/test_utils.rs
Original file line number Diff line number Diff line change
Expand Up @@ -337,10 +337,10 @@ impl LookupExecutorBuilder for FakeInnerSideExecutorBuilder {
}
}

pub struct BlockExecutorBuidler {}
pub struct BlockExecutorBuilder {}

#[async_trait::async_trait]
impl BoxedExecutorBuilder for BlockExecutorBuidler {
impl BoxedExecutorBuilder for BlockExecutorBuilder {
async fn new_boxed_executor<C: BatchTaskContext>(
_source: &ExecutorBuilder<'_, C>,
_inputs: Vec<BoxedExecutor>,
Expand Down Expand Up @@ -374,10 +374,10 @@ impl BlockExecutor {
}
}

pub struct BusyLoopExecutorBuidler {}
pub struct BusyLoopExecutorBuilder {}

#[async_trait::async_trait]
impl BoxedExecutorBuilder for BusyLoopExecutorBuidler {
impl BoxedExecutorBuilder for BusyLoopExecutorBuilder {
async fn new_boxed_executor<C: BatchTaskContext>(
_source: &ExecutorBuilder<'_, C>,
_inputs: Vec<BoxedExecutor>,
Expand Down
2 changes: 1 addition & 1 deletion src/batch/src/executor/update.rs
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ use crate::executor::{
};
use crate::task::BatchTaskContext;

/// [`UpdateExecutor`] implements table updation with values from its child executor and given
/// [`UpdateExecutor`] implements table update with values from its child executor and given
/// expressions.
// Note: multiple `UPDATE`s in a single epoch, or concurrent `UPDATE`s may lead to conflicting
// records. This is validated and filtered on the first `Materialize`.
Expand Down
2 changes: 1 addition & 1 deletion src/common/proc_macro/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ pub fn derive_estimate_size(input: TokenStream) -> TokenStream {
// that we can manipulate
let ast: syn::DeriveInput = syn::parse(input).unwrap();

// The name of the sruct.
// The name of the struct.
let name = &ast.ident;

// Extract all generics we shall ignore.
Expand Down
6 changes: 3 additions & 3 deletions src/connector/src/sink/doris.rs
Original file line number Diff line number Diff line change
Expand Up @@ -229,7 +229,7 @@ pub struct DorisSinkWriter {
pub config: DorisConfig,
schema: Schema,
pk_indices: Vec<usize>,
inseter_inner_builder: InserterInnerBuilder,
inserter_inner_builder: InserterInnerBuilder,
is_append_only: bool,
client: Option<DorisClient>,
row_encoder: JsonEncoder,
Expand Down Expand Up @@ -290,7 +290,7 @@ impl DorisSinkWriter {
config,
schema: schema.clone(),
pk_indices,
inseter_inner_builder: doris_insert_builder,
inserter_inner_builder: doris_insert_builder,
is_append_only,
client: None,
row_encoder: JsonEncoder::new_with_doris(
Expand Down Expand Up @@ -379,7 +379,7 @@ impl DorisSinkWriter {
impl SinkWriter for DorisSinkWriter {
async fn write_batch(&mut self, chunk: StreamChunk) -> Result<()> {
if self.client.is_none() {
self.client = Some(DorisClient::new(self.inseter_inner_builder.build().await?));
self.client = Some(DorisClient::new(self.inserter_inner_builder.build().await?));
}
if self.is_append_only {
self.append_only(chunk).await
Expand Down
2 changes: 1 addition & 1 deletion src/meta/src/stream/scale.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1654,7 +1654,7 @@ impl ScaleController {

for worker_id in &worker_ids {
if unschedulable_worker_ids.contains(worker_id) {
bail!("Cannot include unscheduable worker {}", worker_id)
bail!("Cannot include unschedulable worker {}", worker_id)
}
}

Expand Down
2 changes: 1 addition & 1 deletion src/storage/src/hummock/sstable/block.rs
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ pub struct RestartPoint {

impl RestartPoint {
fn size_of() -> usize {
// store key_len_type and value_len_type in u8 related to `BlockBuidler::build`
// store key_len_type and value_len_type in u8 related to `BlockBuilder::build`
// encoding_value = (key_len_type << 4) | value_len_type
std::mem::size_of::<u32>() + std::mem::size_of::<LenType>()
}
Expand Down

0 comments on commit 4eacb34

Please sign in to comment.