文档首页/ MapReduce服务 MRS/ 组件操作指南(LTS版)/ 使用Flink/ Flink常见问题/ Flink对接Elasticsearch作业运行一段时间后Checkpoint失败
更新时间:2025-07-14 GMT+08:00

Flink对接Elasticsearch作业运行一段时间后Checkpoint失败

问题现象

Flink对接Elasticsearch作业,运行一段时间(TGT的有效期一般为24小时)后,写Elasticsearch失败,Checkpoint超时报错。

TGT(Ticket Granting ticket):票据授权票据。

解决方法

Flink对接Elasticsearch作业在运行过程中,TGT超期后会重新进行认证,此时Elasticsearch缓存的票据信息没有更新,导致认证失败。可通过在“客户端安装路径/Flink/flink/conf/flink-conf.yaml”的“env.java.opts”配置项中添加如下参数解决。

-Djavax.security.auth.useSubjectCredsOnly=true