Hi. I'm using Pyflink and Table APIs to create a window with Python. I have just read the Unit Testing Stateful or Timely UDFs & Custom Operators <https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/datastream/testing/#unit-testing-stateful-or-timely-udfs--custom-operators> section in Flink's docs and it seems that the best way is to use the test harnesses. However, test harnesses are only available with apps written in Java and I have not found anything similar for Python yet.
So what is the proper way to unit test stateful operators, i.e. window, in a Pyflink app at this moment? Thanks in advance. -- ------------------------------------------------------------ -------------------------------------------------- Nguyen Dich Long, School of Information and Communication Technology (SoICT - https://www.soict.hust.edu.vn) Hanoi University of Science and Technology (https://www.hust.edu.vn) 601, B1 Building - No 1, Dai Co Viet Street, Hai Ba Trung District, Ha Noi, Vietnam Tel: +84 (0)3.54.41.76.76 Email: long.nd162...@sis.hust.edu.vn; longnguyen25111...@gmail.com
