Repository navigation

[Java Harness] Handle swallowed exceptions across fused DoFns - #41285

Open

knockknock10 wants to merge 37 commits into

apache:masterfrom

knockknock10:fix/34419-fused-dofn-exception-propagation

Open

[Java Harness] Handle swallowed exceptions across fused DoFns#41285
knockknock10 wants to merge 37 commits into
apache:masterfrom
knockknock10:fix/34419-fused-dofn-exception-propagation

Commits on Nov 13, 2026
- Track exceptions thrown by fused downstream consumers
  knockknock10
  committed
  c26947d
- Apply fused DoFn exception policy at bundle completion
  knockknock10
  committed
  a51f5ae
- Define fused DoFn exception handling experiment
  knockknock10
  committed
  680b404
- Test fused DoFn exception handling policies
  knockknock10
  committed
  4e9046f
- Add fused two-DoFn bundle regression tests
  knockknock10
  committed
  0b9b7bd
- Fix imports in fused DoFn regression test
  knockknock10
  committed
  71bd2bc
- Correct fused regression source data receiver typing
  knockknock10
  committed
  1239f9b
- Format fused test source receiver
  knockknock10
  committed
  54fabd1
- Fix Java test imports
  knockknock10
  committed
  ad327c3
- Fix Java test imports
  knockknock10
  committed
  57a45ed
- Use WindowedValues helper in fused test
  knockknock10
  committed
  84ff929
- Use typed PCollection consumer in fused test
  knockknock10
  committed
  6714eb0
- Match fused DoFn output mapping to its main output tag
  knockknock10
  committed
  253ad2b
- Document fused DoFn exception handling
  knockknock10
  committed
  741fdb3
- Document fused DoFn exception handling
  knockknock10
  committed
  fbcb6c8
- Document fused DoFn exception handling
  knockknock10
  committed
  7668378
- Exercise fail-fast behavior across multiple fused inputs
  knockknock10
  committed
  4751c88
- Separate fused failure and warning completion actions
  knockknock10
  committed
  8a302c3
- Log fused warnings only after successful bundle work
  knockknock10
  committed
  922457a
- Update registry tests for completion policies
  knockknock10
  committed
  7a83495
- Clarify failure tracker reset lifecycle
  knockknock10
  committed
  b803259
- Fix Error Prone MissingFail warnings in registry tests
  knockknock10
  committed
  2c0f969
- Fix fused exception test input stream
  knockknock10
  committed
  b356d64
- Limit fused fail-fast to the downstream transform that failed
  knockknock10
  committed
  b1c33ce
- Avoid relogging previously recorded fused failures
  knockknock10
  committed
  1bef43e
- Always shut down handlers in fused exception tests
  knockknock10
  committed
  f304405
- Cover successful bundle completion in warning mode
  knockknock10
  committed
  761f862
- Handle Error subclasses and isolate failed fused consumers
  knockknock10
  committed
  73d5bd0
- Fail fused bundles before finishing failed DoFns
  knockknock10
  committed
  21549c9
- Test fused consumer isolation and Error propagation
  knockknock10
  committed
  97fcdf1
- Test finish-bundle suppression after fused failures
  knockknock10
  committed
  82221e2
- Preserve cancellation semantics in fused fail mode
  knockknock10
  committed
  7c3e489
- Reset fused exception test counters before each test
  knockknock10
  committed
  cf50026
- Clean up bundle processors when swallowed errors fail bundles
  knockknock10
  committed
  7ac28dc
- Keep metrics consistent when all fused consumers have failed
  knockknock10
  committed
  d16dffe
- Preserve metrics for PCollections without consumers
  knockknock10
  committed
  e648eea
- Reset fused DoFn test counters between tests
  knockknock10
  committed
  928e9f5

Commits

Commits on Nov 13, 2026