👍, zhisheng
我觉得支持ES鉴权在生产中是蛮有用的功能，nice to have，
如jinhai所说，可以先提个improvement的issue，在社区里讨论下(具体参数名，这些参数应该是可选的)，讨论一致后开PR就可以了。
Best,
Leonard
> 在 2020年3月25日，13:51，jinhai wang 写道：
>
> 优秀！可以提个improve issue
>
>
> Best Regards
>
> jinhai...@gmail.com
>
>> 2020年3月25日 下午1:40，zhisheng 写道：
>>
>>
优秀！可以提个improve issue
Best Regards
jinhai...@gmail.com
> 2020年3月25日 下午1:40，zhisheng 写道：
>
> hi，Leonar Xu
>
> 官方 ES DDL 现在不支持填写 ES 集群的用户名和密码，我现在在公司已经做了扩展，加了这个功能，请问社区是否需要这个功能？我该怎么贡献呢？
>
> 效果如图：http://zhisheng-blog.oss-cn-hangzhou.aliyuncs.com/2020-03-25-053948.png
>
> Best Wishes！
>
> zhishe
hi，Leonar Xu
官方 ES DDL 现在不支持填写 ES 集群的用户名和密码，我现在在公司已经做了扩展，加了这个功能，请问社区是否需要这个功能？我该怎么贡献呢？
效果如图：http://zhisheng-blog.oss-cn-hangzhou.aliyuncs.com/2020-03-25-053948.png
Best Wishes！
zhisheng
Leonard Xu 于2020年3月24日周二 下午5:53写道：
> Hi, 出发
> 看起来是你缺少了依赖es connector的依赖[1]，所以只能找到内置的filesystem connector，目前
Hi, 出发
看起来是你缺少了依赖es connector的依赖[1]，所以只能找到内置的filesystem connector，目前内置的filesystem
connector只支持csv format，所以会有这个错误。
在项目中加上缺失的依赖即可，如果使用SQL CLI，也需要将依赖的jar包放到 flink的lib目录下。
org.apache.flink
flink-sql-connector-elasticsearch6_2.11
${flink.version}
org.apache.flink
flink-json
