I think this would not necessarily be a problem. If the async operation is directly after the enrichment operation the enriched operations will be directly forwarded to the async operation. (With a copy step, that can be disabled by enabling object reuse at the StreamExecutionEnvironment)
Best, Aljoscha > On 7. Jul 2017, at 15:59, PedroMrChaves <pedro.mr.cha...@gmail.com> wrote: > > Hello, > > I wanted to keep the data locally, if I associate the fetched metadata with > eachevent (in an enrichment phase) it would considerably increase their size > since the metadata that I need to process the event in the async I/O is to > large. > > Regards, > Pedro. > > > > ----- > Best Regards, > Pedro Chaves > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-AsyncFunction-be-applied-to-connected-streams-tp14137p14148.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
