diff --git a/flow/connectors/postgres/cdc.go b/flow/connectors/postgres/cdc.go
index bf19f0fabb..bd3f9fc40e 100644
--- a/flow/connectors/postgres/cdc.go
+++ b/flow/connectors/postgres/cdc.go
@@ -78,7 +78,7 @@ func getChildToParentRelIdMap(ctx context.Context, pool *pgxpool.Pool) (map[uint
 		FROM pg_inherits
 				JOIN pg_class parent            ON pg_inherits.inhparent = parent.oid
 				JOIN pg_class child             ON pg_inherits.inhrelid   = child.oid
-		WHERE parent.relking='p';
+		WHERE parent.relkind='p';
 	`
 
 	rows, err := pool.Query(ctx, query, pgx.QueryExecModeSimpleProtocol)