| Actor | Fragment | Worker | State |
|---|---|---|---|
| 737249 | 52152 | 51 | running |
| 737250 | 52152 | 51 | running |
CREATE SINK search.team_to_parties_sink AS SELECT team_id, party_id, updated_at FROM authz.team_to_parties_mv WITH ( connector='postgres', host='search-service-db-cluster-rw.alinma-int.svc.cluster.local.', port='5432', user='search_service', password='***', database='paradedb', table='team_to_parties', schema='search', type='upsert', force_compaction='true', primary_key='team_id,party_id' )