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

support failed task after connector restart #383

Open
fireroundgithub opened this issue Nov 18, 2022 · 3 comments · May be fixed by #386
Open

support failed task after connector restart #383

fireroundgithub opened this issue Nov 18, 2022 · 3 comments · May be fixed by #386
Labels
enhancement New feature or request

Comments

@fireroundgithub
Copy link
Contributor

I'd like do it, but need some help.
This issue was shown in RocketMQ SIG 社区 Task list. Who can describe this problem more detail. @odbozhou

@odbozhou odbozhou added the enhancement New feature or request label Nov 18, 2022
@odbozhou
Copy link
Contributor

当前Connector只支持创建,停止,pause/resume,不支持Connector的重启更不支持Task的重启
如果Connector出问题或者某一个task出问题时,只能对connector stop然后重新创建,无法对connector直接restart,更不能对制定的task做重启操作

所以希望新增一下能力
POST /connectors/{connectorName}/restart 重启connector
POST /connectors/{connectorName}/tasks/{taskNum}/restart 重启指定的task

可以先看下runtime中,connector pause/resume的实现
整体的处理流程是是类似的,主要区别是restart是对connector或者task 先等待全部stop再start
等待全部stop和start基本已经实现

@sunheyi6
Copy link

sunheyi6 commented Dec 2, 2022

整体的处理流程是是类似的,主要区别是restart是对connector或者task 先等待全部stop再start

@odbozhou 重启一个 connector或者task的时候,需要停止所有的connector或者一个connector下的所有task,无法针对单个connector或者task重启?

@odbozhou
Copy link
Contributor

odbozhou commented Dec 2, 2022

目前都是都是connector维度启停connector相关的任务,这个issue所描述的特性就是增加task维度支持启停的能力

@sunheyi6 sunheyi6 linked a pull request Dec 3, 2022 that will close this issue
6 tasks
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

Successfully merging a pull request may close this issue.

3 participants