Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5823
Thank you very much @zentol . I have updated the PR. Not sure whether to
meet the demand 100%. For verify the job was successfully run, I used
Elasticsearch2 as a sink. As well add a elasticsearch2 dependency to archetype
pom.xml. Could you take another look ?---
