| Actor | Fragment | Worker | State |
|---|---|---|---|
| 32529 | 11072 | 33 | running |
| 32807 | 11070 | 33 | running |
| 32808 | 11070 | 33 | running |
| 32809 | 11071 | 33 | running |
| 32810 | 11073 | 33 | running |
| 32811 | 11073 | 33 | running |
CREATE TABLE asset_service.benchmark_values_ft (
benchmark_id VARCHAR,
date DATE,
amount DECIMAL,
PRIMARY KEY (benchmark_id, date),
WATERMARK FOR date AS CAST((
date - INTERVAL '5 YEARS'
) AS DATE) WITH TTL
)
WITH (
snapshot='true'
) FROM asset_service.asset_service_source TABLE 'public.benchmark_values_ft'