Skip to content

Commit

Permalink
CR
Browse files Browse the repository at this point in the history
  • Loading branch information
DevilExileSu committed Aug 7, 2023
1 parent a6b4a3e commit 0561f6c
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions src/datanode/src/sql/truncate_table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -35,15 +35,18 @@ impl SqlHandler {
let table = self.get_table(&table_ref).await?;
let engine_procedure = self.engine_procedure(table)?;

let procedure =
TruncateTableProcedure::new(req, self.catalog_manager.clone(), engine_procedure);
let procedure = TruncateTableProcedure::new(
req.clone(),
self.catalog_manager.clone(),
engine_procedure,
);

let procedure_with_id = ProcedureWithId::with_random_id(Box::new(procedure));
let procedure_id = procedure_with_id.id;

info!(
"Truncate table {} by procedure {}",
table_name, procedure_id
"Truncate table {}, table-id {} by procedure {}",
table_ref, req.table_id, procedure_id
);

let mut watcher = self
Expand Down

0 comments on commit 0561f6c

Please sign in to comment.