| Actor | Fragment | Worker | State |
|---|---|---|---|
| 96067 | 18907 | 26 | running |
| 98396 | 18905 | 26 | running |
| 98397 | 18905 | 26 | running |
| 98459 | 18906 | 26 | running |
| 98460 | 18908 | 26 | running |
| 98461 | 18908 | 26 | 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, fees JSONB, 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'