-
Notifications
You must be signed in to change notification settings - Fork 283
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
s3: increase defaultBufferChanSize #1469
Conversation
fix bug issue pingcap#1259 reported temporarily
@amyangfei @3pointer @leoppro PTAL |
I think this is a workaround for current sink design. The MySQL sink uses an unlimited buffer (txn cache), but it has some OOM risk. We need a general back pressure mechanism in sink or built on sink. Well I think it is all right to increase the default channel size. |
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.
LGTM
LGTM |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: eb3bdcd
|
@dengqee: Your PR was out of date, I have automatically updated it for you. Instructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the ti-community-infra/tichi repository. |
Codecov Report
@@ Coverage Diff @@
## master #1469 +/- ##
================================================
+ Coverage 52.9294% 52.9419% +0.0124%
================================================
Files 152 152
Lines 16027 16027
================================================
+ Hits 8483 8485 +2
+ Misses 6649 6646 -3
- Partials 895 896 +1 |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: 34bde23
|
/run-leak-tests |
/merge |
Signed-off-by: ti-srebot <ti-srebot@pingcap.com>
cherry pick to release-4.0 in PR #1631 |
Signed-off-by: ti-srebot <ti-srebot@pingcap.com>
cherry pick to release-5.0 in PR #1632 |
Signed-off-by: ti-srebot <ti-srebot@pingcap.com> Co-authored-by: dengqee <46436429+dengqee@users.noreply.github.com> Co-authored-by: amyangfei <yangfei@pingcap.com> Co-authored-by: Ti Chi Robot <ti-community-prow-bot@tidb.io>
fix bug issue #1259 reported temporarily
What problem does this PR solve?
fix bug issue #1259 reported temporarily
What is changed and how it works?
increase the defaultBufferChanSize of s3, avoiding the
l.units[hash].dataChan()
full, and blocking theprocessor.output
output rows.https://github.com/pingcap/ticdc/blob/04e028419387871b80ddc95377751092f03f26ae/cdc/sink/cdclog/utils.go#L164-L170
Check List
Tests
Code changes
Side effects
Related changes
Release note