fn wire_iceberg_update_lists(node: &mut StreamNode) -> Result<()>Expand description
Pair each update List with its own Fetch before exchanges split them into fragments. Source IDs are not job IDs: two scans of the same source must not share completion state.