[
https://issues.apache.org/jira/browse/FLINK-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-7157:
----------------------------------
Labels: auto-deprioritized-major auto-deprioritized-minor (was:
auto-deprioritized-major stale-minor)
Priority: Not a Priority (was: Minor)
This issue was labeled "stale-minor" 7 days ago and has not received any
updates so it is being deprioritized. If this ticket is actually Minor, please
raise the priority and ask a committer to assign you the issue or revive the
public discussion.
> Provide support for asynchronous operations over connected streams
> ------------------------------------------------------------------
>
> Key: FLINK-7157
> URL: https://issues.apache.org/jira/browse/FLINK-7157
> Project: Flink
> Issue Type: New Feature
> Components: API / DataStream
> Reporter: Pedro Miguel Rainho Chaves
> Priority: Not a Priority
> Labels: auto-deprioritized-major, auto-deprioritized-minor
>
> The asynchronous function provides a great way to process events in parallel,
> which can greatly increase the throughput. However, a user may want to
> process events in parallel based on a stored state created by another stream.
> For instance, one could have a stream of scripts (e.g. groovy scripts) and a
> stream of events. Processing the events by the scripts in a CoFlatMap greatly
> reduces the performance if those take a long time to execute, specially in
> cases with a high number of scripts.
> One could argue that increasing the parallelism of the CoFlatMap would solve
> the problem, however it would come at a very high resource cost.
> It would be nice to have a *CoAsyncFunction* which would allow one of the
> streams in a *connectedStream* to be processed in an asynchronous fashion.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
