-
Notifications
You must be signed in to change notification settings - Fork 286
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
cli(ticdc): Allow overwriting checkpoint ts when resuming a changefeed #6020
cli(ticdc): Allow overwriting checkpoint ts when resuming a changefeed #6020
Conversation
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by submitting an approval review. |
/cc @asddongmen |
@@ -120,7 +116,7 @@ func (m *feedStateManager) shiftStateWindow(state model.FeedState) { | |||
m.stateHistory[defaultStateWindowSize-1] = state | |||
} | |||
|
|||
func (m *feedStateManager) Tick(state *orchestrator.ChangefeedReactorState) { | |||
func (m *feedStateManager) Tick(state *orchestrator.ChangefeedReactorState) (adminJobPending bool) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is a good idea to return a value in the tick method ?
/run-integration-tests |
A failed unit test is under fixing. |
/cc @liuzix |
7b49cf7
to
9b51968
Compare
/run-integration-tests |
/run-unit-tests |
/hold |
/unhold |
/run-integration-tests |
/cc @crelax |
/run-verify |
Codecov Report
Flags with carried forward coverage won't be shown. Click here to find out more. @@ Coverage Diff @@
## cli-use-open-api #6020 +/- ##
========================================================
- Coverage 58.4156% 51.9889% -6.4267%
========================================================
Files 708 240 -468
Lines 83743 39393 -44350
========================================================
- Hits 48919 20480 -28439
+ Misses 30373 16810 -13563
+ Partials 4451 2103 -2348 |
/run-integration-tests |
What problem does this PR solve?
Issue Number: close #5684 #6021
What is changed and how it works?
--overwrite-checkpoint-ts
inchangefeed resume
, which allows users to specify a new changefeed checkpoint ts in the range of (GCSafeTime, CurrentTSO]. By this way, a changefeed in failed state can be resumed with an overwritten checkpoint ts instead of removing and then recreating a changefeed.defaultBackoffMaxElapsedTime
to control the total retry time of changefeed. If that time elapses, the changefeed will enter intofailed
state. However, some users think that it's not a good idea becausegc-ttl
is still in valid range. So in this PR, we removedefaultBackoffMaxElapsedTime
and allow changefeed retry continuously ifgc-ttl
is in that valid range.Check List
Tests
Questions
Will it cause performance regression or break compatibility?
No
Do you need to update user documentation, design documentation or monitoring documentation?
Yes
Release note