I am using flink v1.71 now, and can not find the library you suggested, is it deprecated?
Lifei Chen <hust...@gmail.com> 于2019年2月28日周四 上午9:50写道： > Thanks, I will try it ! > > Congxian Qiu <qcx978132...@gmail.com> 于2019年2月27日周三 下午9:17写道： > >> 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? >>> >>
