From 772d9d14775fe4c3a991f2d88cdbb975587ae133 Mon Sep 17 00:00:00 2001
From: st1page <1245835950@qq.com>
Date: Thu, 9 May 2024 20:00:32 +0800
Subject: [PATCH] fix

---
 src/frontend/src/handler/create_source.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/frontend/src/handler/create_source.rs b/src/frontend/src/handler/create_source.rs
index 537c0444b067c..c77f79c47a2d2 100644
--- a/src/frontend/src/handler/create_source.rs
+++ b/src/frontend/src/handler/create_source.rs
@@ -1385,13 +1385,14 @@ pub async fn bind_create_source(
         )
         .into());
     }
-    let (mut columns, pk_col_ids, row_id_index) = bind_pk_on_relation(columns, pk_names, true)?;
 
     for c in &mut columns {
         c.column_desc.column_id = col_id_gen.generate(c.name())
     }
     debug_assert!(is_column_ids_dedup(&columns));
 
+    let (mut columns, pk_col_ids, row_id_index) = bind_pk_on_relation(columns, pk_names, true)?;
+
     let watermark_descs =
         bind_source_watermark(session, source_name.clone(), source_watermarks, &columns)?;
     // TODO(yuhao): allow multiple watermark on source.