diff --git a/src/frontend/src/instance/distributed.rs b/src/frontend/src/instance/distributed.rs
index d504b05d6e..6405cd8c4c 100644
--- a/src/frontend/src/instance/distributed.rs
+++ b/src/frontend/src/instance/distributed.rs
@@ -294,7 +294,10 @@ impl DistInstance {
                 explain(Box::new(stmt), self.query_engine.clone(), query_ctx).await
             }
             Statement::Insert(insert) => {
-                let (catalog, schema, table) = insert.full_table_name().context(ParseSqlSnafu)?;
+                let (catalog, schema, table) =
+                    table_idents_to_full_name(insert.table_name(), query_ctx)
+                        .map_err(BoxedError::new)
+                        .context(error::ExternalSnafu)?;
 
                 let table = self
                     .catalog_manager