Re: Python API + Unit Testing

Posted by Kevin Lam on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Python-API-Unit-Testing-tp42363p42394.html

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 <[hidden email]> 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 <[hidden email]> 写道：

Hi all,

I noticed there isn't much in the way of testing discussed in the Python API docs for Flink.

Does the community have any best-practices or recommendations on how testing should be done with PyFlink? 

Thanks!