Re: Unit test harness for Sources

2022-02-15 Thread James Sandys-Lumsdaine
Thanks for the reply. If I upgrade my legacy Sources to use the new split Sources is there a better unit test harness for that? Thanks, James. Sent from my iPhone On 15 Feb 2022, at 13:24, Chesnay Schepler wrote:  I don't think there is anything of the sort for the legacy sources. I would

Re: Unit test harness for Sources

2022-02-15 Thread Chesnay Schepler
I don't think there is anything of the sort for the legacy sources. I would suggest to follow the example at https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/testing/#testing-flink-jobs and using a job that only contains the source (+ something to either extract

Unit test harness for Sources

2022-02-14 Thread James Sandys-Lumsdaine
Hi all, I've been using the test harness classes to unit test my stateful 1 and 2 stream functions. But I also have some stateful legacy Source classes I would like to unit test and can't find any documentation or example for that - is this possible? Thanks, James.