[WIP][SYSTEMDS-3946] Merge PR Enable sending of large (>2GiB) FederatedRequests - #2591

Open

ywcb00 wants to merge 13 commits into

apache:mainfrom

Commits on Aug 18, 2026

[SYSTEMDS-3946] Enable sending of large (>2GiB) FederatedRequests and Responses

Biranavan-Parameswaran
authored and
ywcb00
committed
9b37cf9
[SYSTEMDS-3946] Streaming codec routing, chunk tuning, tests, review fixes

Biranavan-Parameswaran
authored and
ywcb00
committed
0a3e272
chore: trigger PR update

Biranavan-Parameswaran
authored and
ywcb00
committed
e8d2379
[SYSTEMDS-3946] Fix Eclipse formatting on PR-edited lines

Biranavan-Parameswaran
authored and
ywcb00
committed
0e0f282
[SYSTEMDS-3946] Test chunk codec error propagation and frame release

Biranavan-Parameswaran
authored and
ywcb00
committed
a9a26db
[SYSTEMDS-3946] Rename chunk decoder locals per review

Biranavan-Parameswaran
authored and
ywcb00
committed
05035ba
[SYSTEMDS-3946] Javadoc for the streaming chunk codec

Biranavan-Parameswaran
authored and
ywcb00
committed
f971257
[SYSTEMDS-3946] Test unknown chunk frame type

Biranavan-Parameswaran
authored and
ywcb00
committed
fae75d8
refactor(main/runtime/controlprogram/federated/FederatedChunkProtocol.java): change class and members to visibility public
ywcb00
committed
c2dbcbe
refactor(test/functions/federated/io/FederatedMaxPayloadTest.java): move test to io folder instead of network folder and delete the empty network folder
ywcb00
committed
e6d26b5
fix(main/runtime/controlprogram/federated/FederatedData.java): add the federated request encoder again
ywcb00
committed
90f783d
fix(main/runtime/controlprogram/federated/FederatedResponse.java): modify the predicate if it is reusable by lineage to always be true when the lineage object is not null
ywcb00
committed
17e8db9
chore(**): remove unused imports
ywcb00
committed
9104e36