文档首页/ MapReduce服务 MRS/ 组件开发规范/ Flink应用开发规范/ FlinkSQL Connector开发规范/ FlinkSQL Elasticsearch表开发规则
更新时间：2025-02-12 GMT+08:00
查看PDF
分享

FlinkSQL Elasticsearch表开发规则

Flink支持1.12.2及以后版本，Elasticsearch支持7.10.2及以后版本。

安全模式的Flink对接普通模式的Elasticsearch集群需设置参数“es.security.indication”的值为“false”

  • 安全模式的Flink集群支持对接安全模式和普通模式的Elasticsearch集群。
    当安全模式的Flink集群对接普通模式的Elasticsearch集群时需设置如下参数：
    1. 登录FusionInsight Manager页面，选择“集群 > 服务 > Flink > 配置 > 全部配置”，搜索参数“es.security.indication”，并将FlinkResource角色和FlinkServer角色下该参数的值配置为“false” 。
    2. 重启Flink服务，在“概览”页签，选择“更多 > 重启服务”等待Flink服务重启成功。
  • 普通模式的Flink集群支持对接普通模式的Elasticsearch集群。