Hello, I have built a small Flink app which receive events (json events), deserialize them to an object and then uses the Table API to create two tables, do some join and then write the results back to a kafka stream.
What is the suggested method to correctly test that the code written with the Table API works as expected? Any best practice for ITs ? Is the best way to simply run the app through flink and then test it with some external tools such a small python script? (Using Flink 1.8.3) Thank you, Darlo
