更新时间: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
父主题: Flink常见问题