-
Notifications
You must be signed in to change notification settings - Fork 3k
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
enhance: enable write ahead buffer for streaming service #39549
base: master
Are you sure you want to change the base?
Conversation
[APPROVALNOTIFIER] This PR is NOT APPROVED This pull-request has been approved by: chyezh The full list of commands accepted by this bot can be found here.
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
@chyezh go-sdk check failed, comment |
@chyezh E2e jenkins job failed, comment |
b5aa2c5
to
e718daf
Compare
@chyezh go-sdk check failed, comment |
@chyezh E2e jenkins job failed, comment |
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## master #39549 +/- ##
==========================================
- Coverage 69.40% 69.39% -0.02%
==========================================
Files 302 302
Lines 27065 27070 +5
==========================================
Hits 18785 18785
- Misses 8280 8285 +5
|
e718daf
to
d17833b
Compare
- Make the wal scanner interface same with streaming scanner. - Use wal if the wal is located at current node. - Otherwise fallback the old logic. Signed-off-by: chyezh <[email protected]>
@chyezh E2e jenkins job failed, comment |
@chyezh go-sdk check failed, comment |
d1c52c3
to
ac391ba
Compare
@chyezh E2e jenkins job failed, comment |
- Add a pchannel level checkpoint for flush processing - Refactor the recovery of flushers of wal - make a shared wal scanner first, then make multi datasyncservice on it Signed-off-by: chyezh <[email protected]>
@chyezh go-sdk check failed, comment |
- Make a timetick-commit-based write ahead buffer at write side. - Add a switchable scanner at read side to transfer the state between catchup and tailing read Signed-off-by: chyezh <[email protected]>
ac391ba
to
eb55568
Compare
@chyezh E2e jenkins job failed, comment |
@chyezh go-sdk check failed, comment |
issue: #38399