-
Notifications
You must be signed in to change notification settings - Fork 5.9k
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
sessionctx/variable: set log bin #9310
Conversation
Codecov Report
@@ Coverage Diff @@
## master #9310 +/- ##
================================================
- Coverage 67.2278% 67.1801% -0.0477%
================================================
Files 381 381
Lines 79839 79906 +67
================================================
+ Hits 53674 53681 +7
- Misses 21379 21434 +55
- Partials 4786 4791 +5 |
I have a request for MySQL compatibility:
|
67f6b2b
to
cbd406a
Compare
@WangXiangUSTC PTAL |
cbd406a
to
963090c
Compare
87c0703
to
f8d2571
Compare
e45e389
to
1a8b49d
Compare
@WangXiangUSTC PTAL |
@WangXiangUSTC PTAL |
sessionctx/binloginfo/binloginfo.go
Outdated
} | ||
SetPumpsClient(client) | ||
} | ||
pumpsClientLock.RUnlock() |
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.
you means Unlock()?
} else { | ||
var err error | ||
client, err = CreatePumpsClient() | ||
if err != nil { |
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.
need unlock before return
sessionctx/binloginfo/binloginfo.go
Outdated
var binlogCli *pumpcli.PumpsClient | ||
var err error | ||
if ShouldEnableBinlog() { | ||
atomic.StoreUint32(&variable.ProcessGeneralLog, 1) |
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.
why change this variable?
41b30e4
to
d8439ea
Compare
@yangwenmai don't need support set log_bin now, I will close this pr. Thanks for your contribution |
What problem does this PR solve?
impl #9201
Check List
Tests
Code changes