Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Feature] 实现流应用自动重启并优化幂问题 #89

Open
1 of 2 tasks
yangwenzea opened this issue Jun 28, 2023 · 0 comments
Open
1 of 2 tasks

[Feature] 实现流应用自动重启并优化幂问题 #89

yangwenzea opened this issue Jun 28, 2023 · 0 comments
Labels
enhancement New feature or request

Comments

@yangwenzea
Copy link
Contributor

Search before asking

  • I had searched in the issues and found no similar feature requirement.

Problem Description

Streamis的任务可能会因为各种环境问题发生失败终止的情况(特别是目前Streamis的Flink任务不支持HA自动拉起的情况),所以要识别出Streamis任务异常终止后程序自动重启改任务。

Description

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?

  • Yes I am willing to submit a PR!
@yangwenzea yangwenzea added the enhancement New feature or request label Jun 28, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

No branches or pull requests

1 participant