Skip to content
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.

Sign up for GitHub

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

Jump to bottom

domain: save action type directly instead of left shift it #39660

Merged
merged 13 commits into from
Dec 7, 2022
Merged

domain: save action type directly instead of left shift it #39660

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
de45d8d
domain: save action type directly instead of left shift it
Defined2014 Dec 6, 2022
807916b
update
Defined2014 Dec 6, 2022
8036d5c
update
Defined2014 Dec 6, 2022
6c50b74
fmt
Defined2014 Dec 6, 2022
329daee
update bazel
Defined2014 Dec 6, 2022
49989a1
update
Defined2014 Dec 6, 2022
c10222c
update test
Defined2014 Dec 6, 2022
c653b6f
fix test
Defined2014 Dec 6, 2022
78e444f
update
Defined2014 Dec 6, 2022
8ef9d27
update bazel
Defined2014 Dec 6, 2022
13a58fb
update test
Defined2014 Dec 6, 2022
cd45230
update comments
Defined2014 Dec 6, 2022
5814ace
Merge branch 'master' into fix-39656
Defined2014 Dec 6, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
2 changes: 1 addition & 1 deletion domain/domain.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -347,7 +347,7 @@ func (do *Domain) tryLoadSchemaDiffs(m *meta.Meta, usedVersion, newVersion int64
}
phyTblIDs = append(phyTblIDs, IDs...)
for i := 0; i < len(IDs); i++ {
actions = append(actions, uint64(1<<diff.Type))
actions = append(actions, uint64(diff.Type))
}
}

Expand Down
5 changes: 2 additions & 3 deletions domain/schema_validator.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -149,11 +149,10 @@ func (s *schemaValidator) Update(leaseGrantTS uint64, oldVer, currVer int64, cha
actionTypes = change.ActionTypes
}
for idx, ac := range actionTypes {
// NOTE: ac is not an action type, it is (1 << action type).
if ac == 1<<model.ActionUnlockTable {
if ac == uint64(model.ActionUnlockTable) {
s.do.Store().GetMemCache().Delete(tblIDs[idx])
}
if ac == 1<<model.ActionFlashbackCluster {
if ac == uint64(model.ActionFlashbackCluster) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Do we need to update https://github.com/pingcap/tidb/blob/master/session/schema_amender.go#L46 and https://github.com/pingcap/tidb/blob/master/session/schema_amender.go#L666 like this?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

updated, PTAL @zimulala

s.do.InfoSyncer().GetSessionManager().KillNonFlashbackClusterConn()
}
}
Expand Down