您好！
请问一下，把程序打jar包然后提交集群运行了一天，flink安装目录下的log文件夹里产生了44G日志文件。flink 主要做的接收到消息处理完之后写入数据库，但是通过查看数据库数据的情况，数据也挺完整的没有什么错误，可是tail 查看了一下产生的log文件，里面不停的在产生 error 信息，但是也没有看到具体哪里报错，IDEA 本地运行的时候没有报错。据说要在代码设置默认重启策略，我在代码里开启了checkpoint，“senv.enableCheckpointing(60000) ，看资料说“如果启用了 checkpointing，但没有配置重启策略，则使用固定间隔 (fixed-delay) 策略，其中 Integer.MAX_VALUE 参数是尝试重启次数”。
请问这是什么原因呢？应该如何下手解决？
Locked
