Re: Best way to test Table API and SQL

2020-11-05 Thread Timo Walther
Hi, everything prefixed with `org.apache.flink.table.planner` is Blink planner. So you should be able to use those testing classes. The Blink planner is also the default one since 1.11. In general, I would recommend to look a bit into the testing package. There are many different testing exam

Re: Best way to test Table API and SQL

2020-10-30 Thread Rex Fenley
Hello, Thank you for these examples, they look great. However, I can seem to import `import org.apache.flink.table.planner.runtime.utils.{StreamingTestBase, StringSink}` is it because I'm using the Blink planner and not the regular one? Thanks On Fri, Oct 9, 2020 at 7:55 AM Timo Walther wrote:

Re: Best way to test Table API and SQL

2020-10-09 Thread Timo Walther
Hi Rex, let me copy paste my answer from a similar thread 2 months ago: Hi, this might be helpful as well: https://lists.apache.org/thread.html/rfe3b45a10fc58cf19d2f71c6841515eb7175ba731d5055b06f236b3f%40%3Cuser.flink.apache.org%3E First of all, it is important to know if you are interested i

Best way to test Table API and SQL

2020-10-08 Thread Rex Fenley
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-t