always fix raw definition

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jan 15, 2025 · ff42a06 · ff42a06
1 parent 79bbd11
commit ff42a06
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/frontend/src/handler/create_sink.rs b/src/frontend/src/handler/create_sink.rs
@@ -503,9 +503,7 @@ pub(crate) async fn reparse_table_for_sink(
 ) -> Result<(StreamFragmentGraph, Table, Option<PbSource>)> {
     // Retrieve the original table definition and parse it to AST.
     let definition = table_catalog.create_sql_ast_purified()?;
-    let raw_definition = table_catalog
-        .create_sql_ast()
-        .unwrap_or_else(|_| definition.clone() /* create table as */);
+    let raw_definition = table_catalog.create_sql_ast()?;
 
     let Statement::CreateTable {
         name,