有没有大佬知道flink任务运行一段时间后的kafka consumer就不消费了，kafka端显示

有没有大佬知道flink任务运行一段时间后的kafka consumer就不消费了，kafka端显示消息堆积，flink web界面也显示没有新的数据进来，整个程序也没有报错，也没有挂掉，用的是FlinkKafkaConsumer，这是为啥？能指出一下排查方向也行的，日志都看了也没发现啥原因，thread dump则是看不懂，用的process time，没有管水印时间，而且没有用到窗口，就是数据进来后，查维表信息，判断然后输出，嗯嗯这种情况我也知道，我这种很怪。。。刚又自动重启好了，应该是程序中查维表挂了，然后数据流就一直卡在那里不动了。。。但是没有报错了，过了两个小时，估计超了啥timeout时间了，程序就自动restart了 日志显示刚好2小时，不知道怎么设置这个时间。。。2小时也太长了，应该不是。我这个任务不会存在这种情况，应该是访问维表报错后就一直重试了2h，导致程序这里断了，kafka源端由于反压机制也不消费了，但是为啥这个operator中访问第三方数据报错后，整个任务过2h才会失败重启。。。有没有老哥知道呀？配了，而且是5分钟内，但是重启策略应该是flink job层面的错误才会触发重启，算子层面的错误，好像不会立刻体现在job层面，我这个错误就是flatMap算子中报错的，但是整整2个小时，flink任务都没挂掉