fix: invalidate cache after altering (#2239)

GreptimeTeam · Aug 24, 2023 · a7e0e23 · a7e0e23
1 parent 19d2d77
commit a7e0e23
Showing 1 changed file with 7 additions and 8 deletions.
diff --git a/src/frontend/src/instance/distributed.rs b/src/frontend/src/instance/distributed.rs
@@ -150,10 +150,7 @@ impl DistInstance {
             }
         );
 
-        // Since the table information created on meta does not go through KvBackend, so we
-        // manually invalidate the cache here.
-        //
-        // TODO(fys): when the meta invalidation cache mechanism is established, remove it.
+        // Invalidates local cache ASAP.
         self.catalog_manager
             .invalidate_table(
                 &table_name.catalog_name,
@@ -193,10 +190,7 @@ impl DistInstance {
             .await
             .context(CatalogSnafu)?;
 
-        // Since the table information dropped on meta does not go through KvBackend, so we
-        // manually invalidate the cache here.
-        //
-        // TODO(fys): when the meta invalidation cache mechanism is established, remove it.
+        // Invalidates local cache ASAP.
         self.catalog_manager()
             .invalidate_table(
                 &table_name.catalog_name,
@@ -556,6 +550,11 @@ impl DistInstance {
             .await
             .context(error::RequestMetaSnafu)?;
 
+        // Invalidates local cache ASAP.
+        self.catalog_manager()
+            .invalidate_table(catalog_name, schema_name, table_name, table_id)
+            .await;
+
         Ok(Output::AffectedRows(0))
     }