Hudi作业重试报错Checkpoint超时

遇到Akka Java开发的Flink作业在将Hudi作为目的端时，出现Checkpoint超时导致作业重试，最终报错“Checkpoint expired before completing”与“Checkpoint Coordinator is suspending”，核心原因通常在于Hudi的小文件合并与……