flink现在支持elasticsearch8以上的版本吗?
截至2022年底,阿里云Flink目前已经支持Elasticsearch 8及以上版本。您可以在Flink的官方文档中查看最新的支持版本信息,以确保您的Flink版本与Elasticsearch版本兼容。同时,建议您在使用过程中关注Flink和Elasticsearch的版本更新,及时更新版本以获取更好的性能和功能。
目前阿里云实时计算 Flink 的 Elasticsearch connector 并不支持 Elasticsearch 8.x 的版本,但支持 Elasticsearch 6.x 和 7.x 的版本。
如果需要连接 Elasticsearch 8.x 的版本,建议使用其他方式进行连接,例如在 Flink 中使用 REST API 访问 Elasticsearch 的数据等。另外,Flink 社区也有关于 Elasticsearch 8.x 支持的讨论和计划,可能会在未来版本中添加支持。
Flink 1.14.3 版本已经支持 Elasticsearch 8。
从 Flink 1.12 版本开始,Flink 官方维护了一个 Elasticsearch Connectors 库,该库包含两个 Elasticsearch 连接器:
在 Flink 1.14 版本中,新增了针对 Elasticsearch 8 的连接器 Elasticsearch 8 Connectors。
Flink目前支持的Elasticsearch版本包括Elasticsearch 6.x和Elasticsearch 7.x。
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/datastream/elasticsearch/?spm=a2c6h.13066369.question.11.38c07950ZeVHxe
Flink 官方文档中目前只能找到Elasticsearch 6.x 及Elasticsearch 7.x版本的相关说明,未找到关于Elasticsearch 8相关说明,应是不支持Elasticsearch 8版本及以上,参考文档:Elasticsearch
截至目前(2021年9月),Apache Flink 1.14.0版本已经支持Elasticsearch 7.x版本,但还不支持Elasticsearch 8.x版本。
如果您需要使用Elasticsearch 8.x版本,可以考虑使用Flink的Elasticsearch Sink的自定义实现,或者使用Flink的REST API将数据发送到Elasticsearch。
另外,您也可以关注Flink社区的更新,以获取最新的关于Elasticsearch 8.x版本支持的信息。
截至 Flink 1.14.0 版本,Flink 的 Elasticsearch Connector 支持的 Elasticsearch 版本最高为 7.x。
具体来说,Flink 的 Elasticsearch Connector 0.11.0 版本开始支持 Elasticsearch 7.x,但不支持 Elasticsearch 8.x。而在 Flink 1.15.0-SNAPSHOT 版本中,Elasticsearch Connector 以及对应的 Elasticsearch 依赖已经升级至 7.13.2 版本[2],但仍不支持 Elasticsearch 8.x。
因此,目前 Flink 还不支持 Elasticsearch 8.x 版本,需要使用 Elasticsearch 7.x 版本。
截至目前,Flink 官方仅支持 Elasticsearch 7.x 版本。这是因为 Elasticsearch 8.x 版本中废弃了一些 Flink 目前正在使用的 API,导致 Flink 无法与 Elasticsearch 8.x 进行兼容。
如果需要使用 Elasticsearch 8.x 版本,可以考虑使用 Flink Elasticsearch Connector 的社区版本或自行实现相应的连接器。社区版本主要由 Flink 用户社区维护,可能存在一些局限性和不稳定性,需要自行评估。自行实现连接器需要了解 Elasticsearch 8.x 的 API 变化和 Flink 数据源/数据接收器的实现方式,需要一定的技术能力和时间成本。
建议在选择 Elasticsearch 版本时,根据实际需求和环境情况进行评估和测试,并选择适合的版本。
目前,Flink 官方仅支持 Elasticsearch 7.x 版本,没有官方支持的 Elasticsearch 8.x 版本。
不过,你可以尝试使用 Elasticsearch 8.x 版本,并使用官方提供的 Elasticsearch 连接器的最新版本。虽然官方不保证兼容性,但是有可能可以正常工作。如果你在使用中遇到问题,可以通过 Flink 官方社区渠道来寻求帮助。
Flink的最新版本1.14.x已经支持Elasticsearch 7.x系列的版本。但是目前还不支持Elasticsearch 8.x及以上的版本。如果您需要使用Elasticsearch 8.x及以上版本,可能需要等待Flink更新或者自行修改源代码。
目前 Flink 的 Elasticsearch Connector 只支持 Elasticsearch 5 和 6 版本
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。