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

Sun, 16 Aug 2020 17:35:44 -0700 

谢谢大佬 我先研究研究





------------------ 原始邮件 ------------------
发件人: Leonard Xu <[email protected]&gt;
发送时间: 2020年8月14日 10:25
收件人: user-zh <[email protected]&gt;
主题: 回复：flink-1.10.1 想用 DDL 入 ES5.6



Hi,
我贴的链接里有对应的PR[1], 你可以看看这个PR里的代码，代码入口可以从 Elasticsearch6DynamicSink.java 
<https://github.com/apache/flink/pull/12184/files#diff-c71784e07a5a5c214a2f4f9843e6ef3f&gt;
 开始
比如你自己实现了Elasticsearch5DynamicSink 
<https://github.com/apache/flink/pull/12184/files#diff-c71784e07a5a5c214a2f4f9843e6ef3f&gt;
 一套后，再打一个 es5 的sql jar 就好了。

祝好
Leonard 
[1] https://github.com/apache/flink/pull/12184 
<https://github.com/apache/flink/pull/12184&gt;


&gt; 在 2020年8月14日，10:14，kcz <[email protected]&gt; 写道：
&gt; 
&gt; 查看您说的[1]的url之后，发现里面并没有跟 es sql jar有关的。
&gt; 
&gt; 
&gt; 
&gt; --
&gt; Sent from: http://apache-flink.147419.n8.nabble.com/

回复