diff --git a/src/backend/distributed/cdc/cdc_decoder_utils.c b/src/backend/distributed/cdc/cdc_decoder_utils.c
index a69f307ba..d781f171c 100644
--- a/src/backend/distributed/cdc/cdc_decoder_utils.c
+++ b/src/backend/distributed/cdc/cdc_decoder_utils.c
@@ -184,9 +184,9 @@ CdcExtractShardIdFromTableName(const char *tableName, bool missingOk)
 
 
 /*
- * CdcGetLocalGroupId returns the group identifier of the local node. The function assumes
- * that pg_dist_local_node_group has exactly one row and has at least one column.
- * Otherwise, the function errors out.
+ * CdcGetLocalGroupId returns the group identifier of the local node. The
+ * function assumes that pg_dist_local_group has exactly one row and has at
+ * least one column. Otherwise, the function errors out.
  */
 static int32
 CdcGetLocalGroupId(void)
diff --git a/src/backend/distributed/metadata/metadata_cache.c b/src/backend/distributed/metadata/metadata_cache.c
index 196195b7d..0feb2e2ae 100644
--- a/src/backend/distributed/metadata/metadata_cache.c
+++ b/src/backend/distributed/metadata/metadata_cache.c
@@ -4415,9 +4415,9 @@ RegisterCitusTableCacheEntryReleaseCallbacks(void)
 
 
 /*
- * GetLocalGroupId returns the group identifier of the local node. The function assumes
- * that pg_dist_local_node_group has exactly one row and has at least one column.
- * Otherwise, the function errors out.
+ * GetLocalGroupId returns the group identifier of the local node. The function
+ * assumes that pg_dist_local_group has exactly one row and has at least one
+ * column. Otherwise, the function errors out.
  */
 int32
 GetLocalGroupId(void)