Details
-
Task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
TaskInstance will aggregate the end-of-stream control messages, propagate the result to the StreamOperatorTask. The Task will send end-of-stream to downstream intermediate topics given the upstream inputs to a set of operators are all end-of-stream.
Attachments
Issue Links
- is depended upon by
-
SAMZA-1260 Support Control Messages Across Intermediate Streams
- Resolved
- links to