| Actor | Fragment | Worker | State |
|---|---|---|---|
| 52815 | 2339 | 3 | running |
| 53270 | 2337 | 3 | running |
| 53271 | 2337 | 3 | running |
| 53272 | 2338 | 3 | running |
| 53273 | 2340 | 3 | running |
| 53274 | 2340 | 3 | running |
CREATE TABLE order_service.order_executions ( id VARCHAR, order_id VARCHAR, quantity VARCHAR, price JSONB, commission JSONB, execution_trans_type VARCHAR, executed_at TIMESTAMPTZ, PRIMARY KEY (id), WATERMARK FOR executed_at AS executed_at - INTERVAL '5 YEARS' WITH TTL ) WITH ( snapshot='true' ) FROM order_service.order_service_source TABLE 'oms.order_executions'