How to add unit test for flink sql ?

[Lifei Chen]

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?

[Congxian Qiu]

Hi, Lifei

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

Lifei Chen <[hidden email]> 于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?

[Lifei Chen]

Thanks, I will try it !

Congxian Qiu <[hidden email]> 于2019年2月27日周三 下午9:17写道：

Hi, Lifei

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

Lifei Chen <[hidden email]> 于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?

[Lifei Chen]

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

Lifei Chen <[hidden email]> 于2019年2月28日周四 上午9:50写道：

Thanks, I will try it !

Congxian Qiu <[hidden email]> 于2019年2月27日周三 下午9:17写道：

Hi, Lifei

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

Lifei Chen <[hidden email]> 于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?

[Lifei Chen]

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 <[hidden email]> 于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 <[hidden email]> 于2019年2月28日周四 上午9:50写道：

Thanks, I will try it !

Congxian Qiu <[hidden email]> 于2019年2月27日周三 下午9:17写道：

Hi, Lifei

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

Lifei Chen <[hidden email]> 于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?