Igal Shilman created FLINK-22531:
------------------------------------
Summary: Improve the support for finite streaming jobs with async
operations.
Key: FLINK-22531
URL: https://issues.apache.org/jira/browse/FLINK-22531
Project: Flink
Issue Type: Improvement
Components: Stateful Functions
Affects Versions: statefun-3.0.0
Reporter: Igal Shilman
Finite streaming jobs will terminate even in the presence of asynchronous in
flight operations.
Looking at the AsyncWait operator, it seems that it can be mitigated by using
the following interface:
[https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BoundedOneInput.java#L27]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
