[cdc] always initialize childToParentRelIDMapping

PeerDB-io · Dec 17, 2024 · d394964 · d394964
1 parent 62edd06
commit d394964
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -404,6 +404,8 @@ func pullCore[Items model.Items](
 		if err != nil {
 			return fmt.Errorf("error getting child to parent relid map: %w", err)
 		}
+	} else {
+		childToParentRelIDMap = make(map[uint32]uint32)
 	}
 
 	if err := c.MaybeStartReplication(ctx, slotName, publicationName, req.LastOffset, pgVersion); err != nil {