[flink] Support end input in coordinator commit - #8671

Open

fishfishfishfishaa wants to merge 10 commits into

apache:masterfrom

fishfishfishfishaa:pip30-endinput

Commits on Jul 15, 2026

[flink] Support end input in coordinator commit
fishfishfishfishaa
committed

Commits on Jul 16, 2026

Commits on Jul 17, 2026

Pass endInputWatermark directly to coordinator to approximate original operator commit logic
fishfishfishfishaa
committed
add EndInput ITCase
fishfishfishfishaa
committed

Commits on Jul 21, 2026

[flink] Unify end-input commit completion on coordinator close
fishfishfishfishaa
committed

Commits on Jul 28, 2026