RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local

CREATE SINK insights.transactions_sink AS
SELECT
  t.transaction_id,
  t.account_id,
  t.asset_id,
  t.currency_code,
  t.net_value,
  t.transaction_valuation_date,
  t.transaction_settlement_date,
  tt.type AS transaction_type,
  ft.fee_type
FROM olap.transactions_dm AS t
LEFT JOIN olap.transaction_types_dm AS tt
  ON tt.transaction_type_id = t.transaction_type_id
LEFT JOIN olap.fee_transactions_dm AS ft
  ON ft.transaction_id = t.transaction_id
WITH (
  connector='postgres',
  host='psql-nonprod-uae-derived.postgres.database.azure.com',
  port='6432',
  user='migration_user',
  password='***',
  database='adib-int-insights-db',
  table='transactions_dm',
  schema='insights',
  type='upsert',
  force_compaction='true',
  primary_key='transaction_id'
)