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?