Hi Dian Fu, I meant testing in application development. When I'm developing a Pyflink Pipeline, are there any recommended approaches to testing the Flink application? For instance, how should we test applications end-to-end? Individual operators? I'm interested in the Datastream API.
One approach I could see is using StreamingFileSinks, and validating the output files for a bounded stream. On Thu, Mar 18, 2021 at 10:04 PM Dian Fu <dian0511...@gmail.com> wrote: > Hi, > > Do you mean how to run Python unit test? If so, you could refer to [1] for > more details. > > Regards, > Dian > > [1] > https://cwiki.apache.org/confluence/display/FLINK/Setting+up+a+Flink+development+environment > > 2021年3月18日 下午10:46，Kevin Lam <kevin....@shopify.com> 写道： > > Hi all, > > I noticed there isn't much in the way of testing discussed in the Python > API docs > <https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/> > for Flink. > > Does the community have any best-practices or recommendations on how > testing should be done with PyFlink? > > Thanks! > > >
