| Actor | Fragment | Worker | State |
|---|---|---|---|
| 741823 | 37107 | 51 | running |
| 742591 | 37105 | 51 | running |
| 742592 | 37105 | 51 | running |
| 742593 | 37106 | 51 | running |
| 742609 | 37108 | 51 | running |
| 742610 | 37108 | 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'