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