From 6beea735901209778dd7ea7716f4cb8ee7be7995 Mon Sep 17 00:00:00 2001 From: Ning Sun Date: Fri, 10 Feb 2023 10:09:13 +0800 Subject: [PATCH] fix: use query_ctx in distributed inserts (#965) --- src/frontend/src/instance/distributed.rs | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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