flink-1.10.1 想用 DDL 入 ES5.6,要如何实现?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

flink-1.10.1 想用 DDL 入 ES5.6,要如何实现?

2021-12-07 17:32:55 417 1

flink-1.10.1 想用 DDL 入 ES5.6,要如何实现?*来自志愿者整理的flink邮件归档

取消 提交回答
全部回答(1)
  • 毛毛虫雨
    2021-12-07 21:17:33

    我贴的链接里有对应的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 就好了。*来自志愿者整理的flink

    0 0
相关问答

0

回答

问下 cdc2.2.1 读取mysql部署在flink yarn上 checkpoint 一直失败是

2022-08-11 13:55:28 94浏览量 回答数 0

1

回答

Flink SQL编写的程序要包含什么?

2021-12-09 20:07:50 665浏览量 回答数 1

1

回答

咨询关于flink究竟使用的是log4j1还是log4j2.

2021-12-08 11:05:49 348浏览量 回答数 1

1

回答

flink1.11 sql

2021-12-06 16:52:36 368浏览量 回答数 1

1

回答

Flink SQL都有哪些应用场景?

2021-11-10 14:52:46 335浏览量 回答数 1

1

回答

你们在使用flink sql时碰到下面问题时大概是怎么解决的:#Flink

2021-01-23 20:56:41 482浏览量 回答数 1

1

回答

求助:【SSL证书】如何安装SSL证书到网站

2020-12-09 10:19:03 2506浏览量 回答数 1

1

回答

Blink1.5.1 sql 多次计算问题

2019-08-29 21:08:20 1405浏览量 回答数 1

2

回答

安装新版本wordpress4.6出现500 Internal Server Error的问题:

2016-10-06 11:39:16 3880浏览量 回答数 2

1

回答

关于URL 重写如何实现的问题

2016-06-14 11:36:35 1892浏览量 回答数 1
0
文章
141
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载