Skip to content

Commit 47dd229

Browse files
committed
fix
1 parent f8a96c8 commit 47dd229

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/query/service/src/interpreters/interpreter_table_recluster.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ use derive_visitor::DriveMut;
5454
use log::error;
5555
use log::warn;
5656

57-
use crate::interpreters::hook::vacuum_hook::hook_disk_temp_dir;
57+
use crate::interpreters::hook::vacuum_hook::{hook_clear_m_cte_temp_table, hook_disk_temp_dir};
5858
use crate::interpreters::hook::vacuum_hook::hook_vacuum_temp_files;
5959
use crate::interpreters::interpreter_insert_multi_table::scalar_expr_to_remote_expr;
6060
use crate::interpreters::Interpreter;
@@ -513,6 +513,8 @@ impl ReclusterTableInterpreter {
513513
drop(lock_guard);
514514

515515
// vacuum temp files.
516+
self.ctx.unload_spill_meta();
517+
hook_clear_m_cte_temp_table(&self.ctx)?;
516518
hook_vacuum_temp_files(&self.ctx)?;
517519
hook_disk_temp_dir(&self.ctx)?;
518520

0 commit comments

Comments
 (0)