diff --git a/src/frontend/src/catalog/system_catalog/rw_catalog/rw_rate_limit.rs b/src/frontend/src/catalog/system_catalog/rw_catalog/rw_rate_limit.rs
index 5cb24f7053577..34602461ca3b1 100644
--- a/src/frontend/src/catalog/system_catalog/rw_catalog/rw_rate_limit.rs
+++ b/src/frontend/src/catalog/system_catalog/rw_catalog/rw_rate_limit.rs
@@ -20,6 +20,7 @@ use crate::catalog::system_catalog::SysCatalogReaderImpl;
 use crate::error::Result;
 
 #[derive(Fields)]
+#[primary_key(fragment_id, node_name)]
 struct RwRateLimit {
     fragment_id: i32,
     fragment_type: Vec<String>,