更新时间:2025-02-12 GMT+08:00

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集群。