diff --git a/src/storage/src/hummock/store/state_store.rs b/src/storage/src/hummock/store/state_store.rs index cbbbd149643e2..acb45a8615268 100644 --- a/src/storage/src/hummock/store/state_store.rs +++ b/src/storage/src/hummock/store/state_store.rs @@ -407,7 +407,7 @@ impl LocalHummockStorage { // insert imm to uploader if self.no_upload { - self.event_sender + self.event_sender .send(HummockEvent::ImmToUploader(imm)) .unwrap(); } diff --git a/src/storage/src/store.rs b/src/storage/src/store.rs index d73818bfb2a61..802a97962bf67 100644 --- a/src/storage/src/store.rs +++ b/src/storage/src/store.rs @@ -390,7 +390,11 @@ impl NewLocalOptions { } } - pub fn new_temporary(table_id: TableId, is_consistent_op: bool, table_option: TableOption) -> Self { + pub fn new_temporary( + table_id: TableId, + is_consistent_op: bool, + table_option: TableOption, + ) -> Self { NewLocalOptions { table_id, is_consistent_op, diff --git a/src/stream/src/common/table/state_table.rs b/src/stream/src/common/table/state_table.rs index 9ccbc1802366a..9ffc788a1c38f 100644 --- a/src/stream/src/common/table/state_table.rs +++ b/src/stream/src/common/table/state_table.rs @@ -384,10 +384,10 @@ where is_consistent_op: bool, ) -> Self { let local_state_store = store - .new_local(NewLocalOptions ( + .new_local(NewLocalOptions::new( table_id, is_consistent_op, - table_option: TableOption::default(), + TableOption::default(), )) .await;