scala—如何处理flink中批处理任务的错误

mfuanj7w  于 2021-06-25  发布在  Flink
关注(0)|答案(0)|浏览(276)

在我的flink作业中,有一个特定的任务“groupreduce”,它涉及到可能遇到超时异常的外部系统(这里是elasticsearch)。
简单的try-and-catch是不够的,因为如果发生错误,我不想跳过groupreduce任务。
有没有一种方法,一旦抛出异常,就通知flink以t毫秒的延迟重复该子任务?或者类似的?。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题