-
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
*: use a unified session pool definition AMAP #55170
Conversation
Codecov ReportAll modified and coverable lines are covered by tests ✅
Additional details and impacted files@@ Coverage Diff @@
## master #55170 +/- ##
================================================
+ Coverage 74.8430% 75.3710% +0.5279%
================================================
Files 1568 1569 +1
Lines 364503 439945 +75442
================================================
+ Hits 272805 331591 +58786
- Misses 71976 87725 +15749
- Partials 19722 20629 +907
Flags with carried forward coverage won't be shown. Click here to find out more.
|
aa604a7
to
0b87f6a
Compare
/cc @tangenta @hi-rustin |
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.
some nits
"github.com/pingcap/tidb/pkg/util/chunk" | ||
"github.com/pingcap/tidb/pkg/util/sqlexec" | ||
"github.com/tikv/client-go/v2/util" | ||
cliutil "github.com/tikv/client-go/v2/util" |
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.
cliutil
seems quite confusing, because CLI
usually represents Command Line Interface
. Maybe we should use the full name or use clit
.
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.
Changed to clit
.
pkg/domain/domain.go
Outdated
// Make sure the session is new. | ||
sctx := se.(sessionctx.Context) | ||
ctx := kv.WithInternalSourceType(context.Background(), kv.InternalTxnMeta) | ||
if _, err := sctx.GetSQLExecutor().ExecuteInternal(ctx, "rollback"); err != nil { | ||
se.Close() |
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.
May I ask why do we need to drop this line?
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.
Good catch. It seems the behavior changed. I have reverted it. Please take a look.
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.
Looks good to me. Thanks! 👍
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: hi-rustin, tangenta The full list of commands accepted by this bot can be found here. The pull request process is described here
Needs approval from an approver in each of these files:
Approvers can indicate their approval by writing |
Signed-off-by: JmPotato <[email protected]>
Signed-off-by: JmPotato <[email protected]>
Signed-off-by: JmPotato <[email protected]>
Signed-off-by: JmPotato <[email protected]>
Signed-off-by: JmPotato <[email protected]>
226ce9f
to
47eabc1
Compare
/retest |
@JmPotato: The following test failed, say
Full PR test history. Your PR dashboard. 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 kubernetes-sigs/prow repository. I understand the commands that are listed here. |
What problem does this PR solve?
Issue Number: ref #54434.
What changed and how does it work?
Use a unified session pool definition as much as possible. This is to organize the code for later refactoring work.
Check List
Tests
Release note
Please refer to Release Notes Language Style Guide to write a quality release note.