Hi, Congxian: I found it finally . it did not be included in master branch: https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/stream/sql/JavaSqlITCase.java
but still available in release-1.7 https://github.com/apache/flink/blob/release-1.7/flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/stream/sql/JavaSqlITCase.java Best, Lifei Lifei Chen <hust...@gmail.com> 于2019年2月28日周四 上午9:57写道： > 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? >>>> >>>
