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
smime.p7s
Description: S/MIME cryptographic signature
