fn normalize_update_chunk_by_key( chunk: StreamChunk, key_indices: &[usize], ) -> Option<StreamChunk>