diff --git a/src/operator/src/statement/ddl.rs b/src/operator/src/statement/ddl.rs index 4106cee8bfe3..47739210bd2a 100644 --- a/src/operator/src/statement/ddl.rs +++ b/src/operator/src/statement/ddl.rs @@ -37,7 +37,7 @@ use common_query::Output; use common_telemetry::{debug, info, tracing}; use common_time::Timezone; use datatypes::prelude::ConcreteDataType; -use datatypes::schema::RawSchema; +use datatypes::schema::{COMMENT_KEY, RawSchema}; use datatypes::value::Value; use lazy_static::lazy_static; use partition::expr::{Operand, PartitionExpr, RestrictedOp}; @@ -1142,7 +1142,7 @@ fn create_table_info( }; let desc = if create_table.desc.is_empty() { - create_table.table_options.get("comment").cloned() + create_table.table_options.get(COMMENT_KEY).cloned() } else { Some(create_table.desc.clone()) };