You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Igal Shilman (Jira)" <ji...@apache.org> on 2021/04/29 12:11:00 UTC

[jira] [Created] (FLINK-22531) Improve the support for finite streaming jobs with async operations.

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)