fix(batch): use streaming api for postgres_query when fetching rows from upstream

fix(batch): use streaming api for postgres_query when fetching rows from upstream #35929