Hello I'd like to write a unit test for my Flink Job. It consists mostly of the Table API and SQL using a StreamExecutionEnvironment with the blink planner, from source to sink. What's the best approach for testing Table API/SQL?
I read https://flink.apache.org/news/2020/02/07/a-guide-for-unit-testing-in-apache-flink.html however that seems to cover more for specialized functions with DataStreams vs entire Table API constructs. What I think I'd like is to be able to have some stubbed input sources and mocked out sinks which I use to test against my Tables. Does this seem reasonable? I did find TestStreamEnvironment and maybe that would be useful at least for running the tests locally it seems? https://ci.apache.org/projects/flink/flink-docs-stable/api/java/org/apache/flink/streaming/util/TestStreamEnvironment.html Any help appreciated. Thanks! -- Rex Fenley | Software Engineer - Mobile and Backend Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | FOLLOW US <https://twitter.com/remindhq> | LIKE US <https://www.facebook.com/remindhq>
