[Feature] Automatic restart of streaming applications and optimization of power problems #22
Closed
2 tasks done
Labels
enhancement
New feature or request
Search before asking
Problem Description
Streamis tasks can fail and terminate due to various environmental issues (especially Streamis Flink tasks that currently do not support automatic HA pull-up), so it is important to recognize that the Streamis task automatically restarts if it fails abnormally.
Streamis的任务可能会因为各种环境问题发生失败终止的情况(特别是目前Streamis的Flink任务不支持HA自动拉起的情况),所以要识别出Streamis任务异常终止后程序自动重启改任务。
Description
Note: Task start jobs are unique, so restart/start operations are idempotent and only one job can start at a time
1)先尝试拿到checkpoint信息,如果没有checkpoint信息则查看任务是否有配置checkpoint策略,如果没有则忽略。
2)将checkpoint信息作为task参数放到task信息里,异步启动task任务。
注:任务启动作业是惟一的,所以要求重启/启动操作的幂等性,同一时间内只能有一个作业启动
Use case
No response
solutions
No response
Anything else
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: