Hi, 我贴的链接里有对应的PR[1], 你可以看看这个PR里的代码，代码入口可以从 Elasticsearch6DynamicSink.java <https://github.com/apache/flink/pull/12184/files#diff-c71784e07a5a5c214a2f4f9843e6ef3f> 开始 比如你自己实现了Elasticsearch5DynamicSink <https://github.com/apache/flink/pull/12184/files#diff-c71784e07a5a5c214a2f4f9843e6ef3f> 一套后，再打一个 es5 的sql jar 就好了。
祝好 Leonard [1] https://github.com/apache/flink/pull/12184 <https://github.com/apache/flink/pull/12184> > 在 2020年8月14日，10:14，kcz <573693...@qq.com> 写道： > > 查看您说的[1]的url之后，发现里面并没有跟 es sql jar有关的。 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
