Details
-
New Feature
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
Description
See the thread: https://lists.apache.org/thread.html/5fd81ce371aeaf642665348f8e6940e308e04275dd7072f380f9f945@%3Cdev.beam.apache.org%3E
We need this in order to have truly cross-runner end-to-end exactly once via replay + idempotence.
Attachments
Issue Links
- is a parent of
-
BEAM-4684 Support @RequiresStableInput on Dataflow runner in Java SDK
- Open
-
BEAM-5358 Support @RequiresStableInput on Spark runner
- Open
-
BEAM-5362 Support @RequiresStableInput on Samza runner
- Open
-
BEAM-5363 Java DirectRunner should implement retry and support @RequiresStableInput
- Open
-
BEAM-5359 Support @RequiresStableInput on Flink runner
- Resolved
-
BEAM-5360 Support @RequiresStableInput on Apex runner
- Resolved
-
BEAM-5361 Support @RequiresStableInput on Gearpump runner
- Resolved
- links to