Repository navigation

Clone TransformWithState stateful processors across sibling streaming queries - #41137

Open

damccorm wants to merge 3 commits into

fix/spark4-stateful-processor-shared-plan

Open

Clone TransformWithState stateful processors across sibling streaming queries#41137
damccorm wants to merge 3 commits into
masterfrom
fix/spark4-stateful-processor-shared-plan

Commits on Nov 9, 2026
- Clone TransformWithState stateful processors across sibling streaming queries
  damccorm
  committed
  a4a896c
Commits on Nov 12, 2026
- Use BeamStatefulProcessor.copy() instead of SerializableUtils.clone across leaves
  damccorm
  committed
  d9d9347
Commits on Nov 13, 2026
- Add TODO(#41198) comment on expected counter value in testStatefulParDoSharedAcrossMultipleLeaves
  damccorm
  committed
  8fda97e