flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lifei Chen <hust...@gmail.com>
Subject Re: How to add unit test for flink sql ?
Date Thu, 28 Feb 2019 02:40:02 GMT
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 <hustclf@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 <hustclf@gmail.com> 于2019年2月28日周四 上午9:50写道:
>
>> Thanks, I will try it !
>>
>> Congxian Qiu <qcx978132955@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 <hustclf@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?
>>>>
>>>

Mime
View raw message