Hello Flink experts!
My streaming pipeline makes async IO calls via the recommended AsyncFunction. 
The pipeline evolves and I've encountered a requirement to side output 
additional events from the function.
As it turned out the side output feature is only available in the following 
functions:
ProcessFunction 
CoProcessFunction
ProcessWindowFunction
ProcessAllWindowFunction

Just curious whether there is any known approach of utilizing "side output" 
feature from the AsyncFunction?

From my perspective, the only feasible way of solving this task is to output a 
processing event and an optional "side output" as a tuple from the 
AsyncFunction and then process the resulting stream with a ProcessFunction to 
handle the required logic. But this approach seems to be overcomplicated. 

Am I missing something? Any help/ideas are much appreciated!

Cheers,
Mike Pryakhin

Attachment: smime.p7s
Description: S/MIME cryptographic signature

Reply via email to