LFCanddennis zhuang e395d77626 fix: re-scan stream-backed tables in recursive CTEs [Backport release/v1.2] (#9052) ...

fix: re-scan stream-backed tables in recursive CTEs (#9039)

* fix: re-scan stream-backed tables in recursive CTEs

A recursive CTE re-executes its recursive term on every iteration, but
DfTableProviderAdapter hands StreamScanAdapter a single-use stream built at
planning time. The second iteration failed with "Stream already exhausted"
for every table served through DataSource::get_stream — information_schema,
pg_catalog, the computed entity-graph tables and numbers.

Keep that stream for the first execution and open a new one over the same
scan request for later executions.

Closes #9037



* refactor: drop redundant binding in stream factory



---------


(cherry picked from commit bb9b7e8778)

Signed-off-by: Dennis Zhuang <killme2008@gmail.com>
Co-authored-by: dennis zhuang <killme2008@gmail.com>

2026-09-07 21:01:34 +08:00

..

distributed

fix: backport v1.2.0 correctness and liveness fixes (#9023)

2026-09-07 19:29:54 +08:00

standalone

fix: re-scan stream-backed tables in recursive CTEs [Backport release/v1.2] (#9052)

2026-09-07 21:01:34 +08:00