Repository navigation

[Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer - #40606

Open

prodriguezdefino wants to merge 5 commits into

apache:masterfrom

prodriguezdefino:java/fn-data-elastic-inbound

Open

[Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer#40606
prodriguezdefino wants to merge 5 commits into
apache:masterfrom
prodriguezdefino:java/fn-data-elastic-inbound

Commits on Oct 16, 2026
- Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer
  prodriguezdefino
  committed
  9d92655
- Release inbound permits on failure and poisoned paths
  prodriguezdefino
  committed
  b7532bb
Commits on Oct 17, 2026
- Poison on failed registration, keep elements collectable, quiet short stalls
  prodriguezdefino
  committed
  6f9d444
- Make the DirectStreamObserver stall log tests independent of timing
  prodriguezdefino
  committed
  9388a8a
Commits on Oct 25, 2026
- Check isReady() every 100 messages again in DirectStreamObserver
  prodriguezdefino
  committed
  658b801