Stream Arrow batches on the data-node fragment execution path - #21418

Merged

rishabhmaurya merged 11 commits into

opensearch-project:mainfrom

bowenlan-amzn:mustang-stream-transport-phase1

May 5, 2026

Commits on May 5, 2026

[PR 21454 follow-up] Forward skipsDeserialization in TransportService wrapper
bowenlan-amzn
committed
ec2790a
Stream Arrow batches on the data-node fragment execution path
bowenlan-amzn
committed
1500827
Enable cross-plugin Arrow sharing via extendedPlugins
bowenlan-amzn
committed
5e452ce
Own a service-level allocator and inject it via ExecutionContext
bowenlan-amzn
committed
1f7b6de
Close per-batch VSR in DatafusionResultStreamTests
bowenlan-amzn
committed
4e8ae97
Propagate transport-created task into ExecutionContext
bowenlan-amzn
committed
33b8f8e
Route QueryContext allocator through ArrowAllocatorProvider
bowenlan-amzn
committed
5c70341
Fix sandbox qa integTest cluster config
bowenlan-amzn
committed
c097eb1
Add StreamingCoordinatorReduceIT
bowenlan-amzn
committed
3111df2
Update parquet-data-format netty SHAs to 4.2.13
bowenlan-amzn
committed
2b5a112
Fix Arrow buffer leak on cancelled streaming responses
bowenlan-amzn
committed
089de3e