Hello,
I have created a FLIP for slightly extending the collect() API to
support collecting an arbitrary number of streams, to make it more
useful for testing complex workflows.
https://cwiki.apache.org/confluence/display/FLINK/FLIP-251%3A+Support+collecting+arbitrary+number+of+streams
Looki
I've found that with our current tooling it's frustrating to try to write
good end-to-end tests for real-world jobs with multiple sinks.
DataStream#executeAndCollect() is okay for simple pipelines with one sink,
but in my opinion we do need something like FLIP-251.
The proposed interface looks goo
Makes sense to me. Thank you, Chesnay. +1
David Anderson schrieb am Fr., 8. Juli 2022, 13:56:
> I've found that with our current tooling it's frustrating to try to write
> good end-to-end tests for real-world jobs with multiple sinks.
> DataStream#executeAndCollect() is okay for simple pipelines
+1
Op zo 10 jul. 2022 om 20:30 schreef Konstantin Knauf :
> Makes sense to me. Thank you, Chesnay. +1
>
> David Anderson schrieb am Fr., 8. Juli 2022, 13:56:
>
> > I've found that with our current tooling it's frustrating to try to write
> > good end-to-end tests for real-world jobs with multipl
