Help Center/ MapReduce Service/ Component Development Specifications/ Flink/ FlinkSQL Connector Development/ Flink SQL Elasticsearch Development Rules
Updated on 2025-04-15 GMT+08:00
View PDF
Share

Flink SQL Elasticsearch Development Rules

The section applies to Flink 1.12.2 or later versions and Elasticsearch 7.10.2 or later versions.

To Interconnect Flink in Security Mode with Elasticsearch Clusters in Normal Mode, Set es.security.indication To false

  • Flink clusters in security mode can be interconnected with Elasticsearch clusters in both security mode and normal mode.
    When the Flink cluster in security mode is interconnected with an Elasticsearch cluster in normal mode, set the following parameters:
    1. Log in to FusionInsight Manager, choose Cluster > Services > Flink. Click Configurations > All Configurations, search for the es.security.indication parameter, and set its value to false for both the FlinkResource and FlinkServer roles.
    2. On the Dashboard page, choose More > Restart Service to restart Flink.
  • Flink clusters in normal mode can be interconnected with Elasticsearch clusters in normal mode as well.