Boyuan Zhang created BEAM-11998:
-----------------------------------
Summary: Portable runners should be able to issue checkpoints to
Splittable DoFn
Key: BEAM-11998
URL: https://issues.apache.org/jira/browse/BEAM-11998
Project: Beam
Issue Type: New Feature
Components: runner-flink, runner-spark
Reporter: Boyuan Zhang
To execute unbounded Splittable DoFn over fnapi in streaming mode properly,
portable runners should issue split(ProcessBundleSplitRequest with
fraction_of_remainder > 0) or simply checkpoint(ProcessBundleSplitRequest with
fraction_of_remainder == 0) to SDK regularly to make current bundle finished
processing instead of running forever.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
