Skip to content

Commit b9f2227

Browse files
authored
fix: skipping vacuum inside explicit transaction (#18228)
chore: skipping vacuum inside explicit transaction
1 parent 407c912 commit b9f2227

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

src/query/ee/src/storages/fuse/operations/vacuum_table_v2.rs

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,16 @@ pub async fn do_vacuum2(
8787
ctx: Arc<dyn TableContext>,
8888
respect_flash_back: bool,
8989
) -> Result<Vec<String>> {
90+
{
91+
if ctx.txn_mgr().lock().is_active() {
92+
info!(
93+
"[FUSE-VACUUM2] Transaction is active, skipping vacuum, target table {}",
94+
table.get_table_info().desc
95+
);
96+
return Ok(vec![]);
97+
}
98+
}
99+
90100
let fuse_table = FuseTable::try_from_table(table)?;
91101
let start = std::time::Instant::now();
92102

0 commit comments

Comments
 (0)