diff --git a/src/frontend/src/instance/distributed.rs b/src/frontend/src/instance/distributed.rs index 21c4d00527..dd2be04286 100644 --- a/src/frontend/src/instance/distributed.rs +++ b/src/frontend/src/instance/distributed.rs @@ -515,6 +515,15 @@ impl DistInstance { .await .context(error::RequestMetaSnafu)?; + let table_info = table.table_info(); + self.catalog_manager + .invalidate_table( + &table_info.catalog_name, + &table_info.schema_name, + &table_info.name, + ) + .await; + Ok(Output::AffectedRows(0)) }