Hi, Lifei

Maybe org.apache.flink.table.runtime.stream.sql.JavaSqlITCase can be
helpful.

Best,
Congxian


Lifei Chen <hust...@gmail.com> 于2019年2月27日周三 下午4:20写道:

> Hi, all:
>
> I finished a flink streaming job with flink sql, which read data from
> kafka and write bach to elasticsearch.
>
> I have no idea how to add a unit test for testing sql I wrote,  any
> suggestions?
>

Reply via email to