I'm not quite familiar with ES conector. However, I guess you could check
if there is data going into the sink connector. One way to achieve this is
to set the pipeline.operator-chaining as false and then you could see the
count of input elements for the sink operator.
PS: Just removed the communi
I think you should use [1] or [2] instead. See [3] for more details.
PS: This question is more fit for the user mailing list.
Regards,
Dian
[1]
https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-elasticsearch6_2.11/1.14.4/flink-sql-connector-elasticsearch6_2.11-1.14.4.jar
