Hi Long, I agree with Fabian that currently you have to test it with a e2e job. There are still no such test harnesses for PyFlink jobs.
Regards, Dian On Fri, Nov 5, 2021 at 5:22 PM Long Nguyễn <longnguyen25111...@gmail.com> wrote: > Thanks, Fabian. I'll check it out. > > Hope that Dian can also give me some advice. > > Best, > Long > > On Fri, Nov 5, 2021 at 3:48 PM Fabian Paul <fabianp...@ververica.com> > wrote: > >> Hi, >> >> Since you want to use Table API you probably can write a more high-level >> test around executing the complete program. A good examples are the >> pyflink example programs [1]. >> >> I also could not find something similar to the testing harness from Java. >> I cced Dian maybe he knows more about it. >> >> Best, >> Fabian >> >> [1] >> https://github.com/apache/flink/blob/3a561323f7a81990a4c239a886f8c6c404d92f0a/flink-python/pyflink/examples/table/word_count.py#L118 > > > > -- > ------------------------------------------------------------ > -------------------------------------------------- > 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 >
