| Actor | Fragment | Worker | State |
|---|---|---|---|
| 736973 | 34240 | 51 | running |
| 738348 | 34238 | 51 | running |
| 738349 | 34238 | 51 | running |
| 738350 | 34239 | 51 | running |
| 738364 | 34241 | 51 | running |
| 738365 | 34241 | 51 | 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'