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

Posted to issues@flink.apache.org by "MaGuowei (JIRA)" <ji...@apache.org> on 2016/08/14 01:35:23 UTC

[jira] [Commented] (FLINK-4391) Provide support for asynchronous operations over streams

    [ https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15420158#comment-15420158 ] 

MaGuowei commented on FLINK-4391:
---------------------------------

hi,Jamie
We have already implemented the "async operator" in Blink (Flink in alibaba version). 
This feature is already in our production env. We also have the plan to contribute this feature back to Flink.





> Provide support for asynchronous operations over streams
> --------------------------------------------------------
>
>                 Key: FLINK-4391
>                 URL: https://issues.apache.org/jira/browse/FLINK-4391
>             Project: Flink
>          Issue Type: New Feature
>          Components: DataStream API
>            Reporter: Jamie Grier
>
> Many Flink users need to do asynchronous processing driven by data from a DataStream.  The classic example would be joining against an external database in order to enrich a stream with extra information.
> It would be nice to add general support for this type of operation in the Flink API.  Ideally this could simply take the form of a new operator that manages async operations, keeps so many of them in flight, and then emits results to downstream operators as the async operations complete.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)