| Actor | Fragment | Worker | State |
|---|---|---|---|
| 98964 | 16925 | 26 | running |
| 99685 | 16923 | 26 | running |
| 99686 | 16923 | 26 | running |
| 99739 | 16924 | 26 | running |
| 99740 | 16926 | 26 | running |
| 99741 | 16926 | 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'