任务状态

默认状态下，任务进入提交至引擎后在资源队列中正常等待；以任务A为例，若顺序执行到A缺少资源请求超时时，会进入到超时队列；

当将A’重新提交至资源队列时，会晚于重新提交时间节点之前的任务3，但早于重新提交时间节点之后的任务4、5、6； 若此时3任务执行后，剩余资源不足以执行A‘，则A’继续返回超时队列等待执行；若反复多次后A’在队列中的时间大于最大超时时间，则任务置失败；

通过Flink的CheckPoint机制，平台支持用户手动选择 指定时间点的CheckPoint 或 指定HDFS的文件 对任务进行续跑，在进行系统升级、系统异常、自动上版等情况下数据不丢、不漏、不重;

对任务重跑时，任务已保存的状态均删除，将根据配置的任务参数重新开始执行。当用户进行重跑时，可选择 使用上次任务参数重跑 或 修改Kafka Offset至一个具体的时间点对任务进行重跑。