Re: Iterator Data Sync

2019-03-19 Thread Andrey Zagrebin
Hi Mikhail, could you create a JIRA issue to discuss the change? Best, Andrey On Mon, Mar 18, 2019 at 3:10 PM Mikhail Pryakhin wrote: > Hello Flink community! > > I've come across of employing an "Iterator Data Sync"[1] approach to test > output from a strea

Iterator Data Sync

2019-03-18 Thread Mikhail Pryakhin
Hello Flink community! I've come across of employing an "Iterator Data Sync"[1] approach to test output from a streaming pipeline. The pipeline consists of a single ProcessFunction which side-outputs some events. I'd like to collect both the primary and the side-output stre