-
Notifications
You must be signed in to change notification settings - Fork 289
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
cdc: integrate two phase scheduler #5710
cdc: integrate two phase scheduler #5710
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. |
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
7dbdb99
to
66096f6
Compare
Codecov Report
Flags with carried forward coverage won't be shown. Click here to find out more. @@ Coverage Diff @@
## fb/latency #5710 +/- ##
===============================================
Coverage ? 56.9524%
===============================================
Files ? 684
Lines ? 80425
Branches ? 0
===============================================
Hits ? 45804
Misses ? 30379
Partials ? 4242 |
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
Signed-off-by: Neil Shen <[email protected]>
This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
* cdc: integrate two phase scheduler Signed-off-by: Neil Shen <[email protected]> * tp: fix duplicate topic handlers panic Signed-off-by: Neil Shen <[email protected]> * tp: add From to messages from scheduler Signed-off-by: Neil Shen <[email protected]> * tp: add more comments and fix typo Signed-off-by: Neil Shen <[email protected]> * cdc: fix missing table ID in table meta Signed-off-by: Neil Shen <[email protected]> * cdc: fix processor.tick panic Signed-off-by: Neil Shen <[email protected]> * tp: fix missing processor epoch Signed-off-by: Neil Shen <[email protected]> * tp: fix missing checkpoint ts in burstBalanceTask Signed-off-by: Neil Shen <[email protected]> * tp: fix lost AddTable request during Commit Signed-off-by: Neil Shen <[email protected]> * Revert "cdc: fix processor.tick panic" This reverts commit ebb0f2c.
What problem does this PR solve?
Issue Number: ref #4757
What is changed and how it works?
Integrate two-phase scheduler and fix two bug
Check List
Tests
Questions
Will it cause performance regression or break compatibility?
Do you need to update user documentation, design documentation or monitoring documentation?
Release note