Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Currently, we don't return the chained future from OnMessageAsync and aggregateWatermark to StreamOperatorTask correctly. Due to this, any errors in propagate watermark will not be propagated to the container correctly.
Attachments
Issue Links
- links to