Github user taizilongxu commented on the pull request:
https://github.com/apache/flink/commit/2437da6e54cb48c4e29116b8789fbe4782b17ea7#commitcomment-24300072
In docs/dev/connectors/elasticsearch.md:
In docs/dev/connectors/elasticsearch.md on line 358:
I thinks the code is wrong in scala, it's not work, is there any one to fix
it?---
