基于Canal+Kafka+Flink+Hudi的实时数据入湖链路出现Flink作业频繁重启故障，表现为Kafka偏移量卡住、反序列化异常和checkpoint超时问题，介绍了由表及里的根因排查定位过程与解决。

Flink任务使用RocksDB状态后端和StateTTL时，因Kryo序列化器在后台Compaction线程中无法获取类加载器导致崩溃。文章从问题现象、原因分析、解决方案等方面讲述Flink生产实战。