社区已经在考虑废弃es5的支持了 Best, Yangze Guo
On Mon, Aug 17, 2020 at 5:38 PM kcz <573693...@qq.com> wrote: > > 有一个小问题比较好奇,当时社区为什么没有提供ES5的sql功能,是处于什么考虑吗?因为已经提供了ES5 sinK的connect。 > ------------------ 原始邮件 ------------------ > 发件人: > "kcz" > > <573693...@qq.com>; > 发送时间: 2020年8月17日(星期一) 上午8:34 > 收件人: "user-zh"<user-zh@flink.apache.org>; > > 主题: 回复:flink-1.10.1 想用 DDL 入 ES5.6 > > > > 谢谢大佬 我先研究研究 > > > > > > ------------------ 原始邮件 ------------------ > 发件人: Leonard Xu <xbjt...@gmail.com> > 发送时间: 2020年8月14日 10:25 > 收件人: user-zh <user-zh@flink.apache.org> > 主题: 回复:flink-1.10.1 想用 DDL 入 ES5.6 > > > > 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/