回复:flink-1.10.1 想用 DDL 入 ES5.6

2020-08-17 文章 kcz
tks.收到 -- 原始邮件 -- 发件人: Yangze Guo https://github.com/apache/flink/pull/12184/files#diff-c71784e07a5a5c214a2f4f9843e6ef3fgt; 开始 比如你自己实现了Elasticsearch5DynamicSink

Re: flink-1.10.1 想用 DDL 入 ES5.6

2020-08-17 文章 Yangze Guo
- > 发件人: > "kcz" > > <573693...@qq.com; > 发送时间:2020年8月17日(星期一) 上午8:34 > 收件人:"user-zh" > 主题:回复:flink-1.10.1 想用 DDL 入 ES

回复:flink-1.10.1 想用 DDL 入 ES5.6

2020-08-16 文章 kcz
谢谢大佬 我先研究研究 -- 原始邮件 -- 发件人: Leonard Xu https://github.com/apache/flink/pull/12184/files#diff-c71784e07a5a5c214a2f4f9843e6ef3f; 开始 比如你自己实现了Elasticsearch5DynamicSink

Re: flink-1.10.1 想用 DDL 入 ES5.6

2020-08-13 文章 Leonard Xu
Hi, 我贴的链接里有对应的PR[1], 你可以看看这个PR里的代码,代码入口可以从 Elasticsearch6DynamicSink.java 开始 比如你自己实现了Elasticsearch5DynamicSink

Re: flink-1.10.1 想用 DDL 入 ES5.6

2020-08-13 文章 kcz
查看您说的[1]的url之后,发现里面并没有跟 es sql jar有关的。 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink-1.10.1 想用 DDL 入 ES5.6

2020-08-11 文章 Leonard Xu
Hi, ES5 没有SQL jar,所以不支持,可以参考[1] 支持ES6 的sql connector 的实现,这是在1.11里支持的。 Best Leonard Xu [1] https://issues.apache.org/jira/browse/FLINK-1 7027 > 在 2020年8月11日,11:18,kcz <573693...@qq.com> 写道: > >