Help Center/ MapReduce Service/ Component Development Specifications/ Flink/ Flink Development FAQs/ What Should I Do If Checkpointing Failed After Flink Interconnects with Elasticsearch for a Period of Time?
Updated on 2025-04-15 GMT+08:00

What Should I Do If Checkpointing Failed After Flink Interconnects with Elasticsearch for a Period of Time?

Symptom

Flink interconnected with Elasticsearch and run for a period of time. The ticket granting ticket (TGT) expires in 24 hours. Data failed to be written to Elasticsearch, and a checkpoint timeout error is reported.

Solution

User authentication failed because of the outdated ticket information in Elasticsearch after the TGT expires during job execution. Add the following parameter to the env.java.opts configuration item in the Client installation path/Flink/flink/conf/flink-conf.yaml file.
-Djavax.security.auth.useSubjectCredsOnly=true