[
https://issues.apache.org/jira/browse/FLINK-22531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igal Shilman updated FLINK-22531:
---------------------------------
Description:
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]
Mailing list thread:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Stateful-Functions-Help-for-calling-remote-stateful-function-written-in-Python-td43283.html
was:
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]
> 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
> Priority: Major
>
> 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]
>
> Mailing list thread:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Stateful-Functions-Help-for-calling-remote-stateful-function-written-in-Python-td43283.html
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
