Doris连接Elasticsearch外部表出现连接超时错误的原因与解决

报错信息：

Error Failed to execute sql: java.sql.SQLException: (conn=212930) errCode = 2, detailMessage = (xxx.xxx)[INTERNAL_ERROR]Failed to connect to ES server, errmsg is: [INTERNAL_ERROR]Failed to connect to xxx.xxx.xxx port 9200 : Connection timed out

错误原因 #

• 网络连通性故障：Doris集群（FE、BE节点）与Elasticsearch服务器所在网络未打通，比如防火墙/安全组拦截9200端口、跨网段无路由配置
• ES服务未正常运行：ES节点未启动，或9200端口未被正常监听
• Doris外部表配置错误：表定义中的ES地址、端口填写错误，或连接超时参数设置过短
• 网络/服务负载过高：ES服务器或Doris节点网络带宽耗尽、CPU/内存占用过高，导致连接请求无法及时响应

解决办法 #

• 排查网络连通性
  • 在Doris的FE和BE节点上执行telnet xxx.xxx.xxx 9200或curl http://xxx.xxx.xxx:9200，验证是否能正常访问ES端口
  • 检查ES服务器的防火墙/安全组规则，确保9200端口对Doris集群所有节点开放
  • 确认网络路由配置，保证Doris节点与ES服务器处于可互通的网络环境
• 验证ES服务状态
  • 在ES服务器本地执行curl http://localhost:9200，确认服务正常返回节点信息
  • 查看ES日志文件（默认路径/var/log/elasticsearch/），排查是否有启动失败、端口占用等异常
• 修正Doris外部表配置
  • 核对外部表DDL中的ES地址、端口是否正确，比如是否存在IP拼写错误
  • 创建或修改外部表时，调整连接超时参数，示例：

    CREATE EXTERNAL TABLE es_external_table (
        id INT,
        name STRING
    ) ENGINE=ELASTICSEARCH
    PROPERTIES (
        "es.hosts" = "http://xxx.xxx.xxx:9200",
        "es.connect_timeout" = "30000", -- 设置为30秒，可按需调整
        "es.index" = "test_index"
    );
    

• 降低系统负载
  • 查看Doris节点和ES服务器的资源使用情况（CPU、内存、网络带宽），确认是否存在资源耗尽
  • 若ES集群负载过高，可通过扩容节点、清理过期数据、优化查询语句等方式降低压力

内容的提问来源于stack exchange，提问作者K Ro