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
