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