fix(interactive): fix unexpect result of operator aggregate() + iterate()

[lnfjpt]

What do these changes do?

Related issue number

Fixes
#3177
Query2

[codecov-commenter]

Codecov Report

Merging #3391 (00d8456) into main (608f814) will decrease coverage by 0.02%.
Report is 3 commits behind head on main.
The diff coverage is n/a.

Additional details and impacted files

@@            Coverage Diff             @@
##             main    #3391      +/-   ##
==========================================
- Coverage   41.04%   41.02%   -0.02%     
==========================================
  Files         109      109              
  Lines       11298    11304       +6     
==========================================
+ Hits         4637     4638       +1     
- Misses       6661     6666       +5     

see 1 file with indirect coverage changes

---

Continue to review full report in Codecov by Sentry.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update 4e7d88c...00d8456. Read the comment docs.

[longbinlai]

Can probably set partitions of leave steam as the maximum partitions of input steam and feedback steam.