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
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:
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