I found the problem. I tried to sign timestamps to the operator (I don't know why), and when I did that, because I used the Flink API fluently, I was no longer referencing the operator that contained the side-outputs.
Disregard my question. On Sat, May 22, 2021 at 9:28 PM Marco Villalobos <mvillalo...@kineteque.com> wrote: > I have been struggling for two days with an issue using the DataStream API > in Batch Execution mode. > > It seems as though my side-output has no elements available to downstream > operators. > However, I am certain that the downstream operator received events. > > I logged the side-output element just before it was collected. There are > no exceptions in the logs. > > However, everytime I run the job the side-output appears empty. > > I noticed https://issues.apache.org/jira/browse/FLINK-20517 > > So, I keyed my output tag immediately after retrieving it, and that also > did not help. > > Any advice or information on this would be appreciated. > > Thank you. >
