You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Lifei Chen <hu...@gmail.com> on 2019/02/27 08:19:54 UTC

How to add unit test for flink sql ?

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?

Re: How to add unit test for flink sql ?

Posted by Lifei Chen <hu...@gmail.com>.

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 <hu...@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 <hu...@gmail.com> 于2019年2月28日周四 上午9:50写道：
>
>> Thanks, I will try it !
>>
>> Congxian Qiu <qc...@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 <hu...@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?
>>>>
>>>

Re: How to add unit test for flink sql ?

Posted by Lifei Chen <hu...@gmail.com>.

I am using flink v1.71 now,  and can not find  the library you suggested,
 is it deprecated?

Lifei Chen <hu...@gmail.com> 于2019年2月28日周四 上午9:50写道：

> Thanks, I will try it !
>
> Congxian Qiu <qc...@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 <hu...@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?
>>>
>>

Re: How to add unit test for flink sql ?

Posted by Lifei Chen <hu...@gmail.com>.

Thanks, I will try it !

Congxian Qiu <qc...@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 <hu...@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?
>>
>

Re: How to add unit test for flink sql ?

Posted by Congxian Qiu <qc...@gmail.com>.

Hi, Lifei

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

Best,
Congxian


Lifei Chen <hu...@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?
>