Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
kwannoel committed Jun 7, 2023
1 parent a5831c1 commit c9793ff
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/storage/src/hummock/store/state_store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}
Expand Down
6 changes: 5 additions & 1 deletion src/storage/src/store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
4 changes: 2 additions & 2 deletions src/stream/src/common/table/state_table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down

0 comments on commit c9793ff

Please sign in to comment.