From 132668bcd1f62b8ceceaca75cd9bdc4d6be98432 Mon Sep 17 00:00:00 2001 From: Weny Xu Date: Thu, 13 Jul 2023 15:19:26 +0900 Subject: [PATCH] feat: invalidate table cache after altering (#1951) --- src/frontend/src/instance/distributed.rs | 9 +++++++++ 1 file changed, 9 insertions(+) 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)) }