async fn diff_stream_and_batch_with_sqls( client: &Client, i: usize, batch: &str, stream: &str, mview_name: &str, table: &Table, ) -> Result<()>