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

cdc: replace tableID with Span in TableExecutor and agent #7793

Merged
merged 7 commits into from
Dec 7, 2022
Merged

cdc: replace tableID with Span in TableExecutor and agent #7793

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
56d985b
cdc: refactor TableExecutor interface and agent
overvenus Dec 2, 2022
e3e9681
address comments and lints
overvenus Dec 7, 2022
4e31411
Merge branch 'master' into span-replication/agent
overvenus Dec 7, 2022
aee994a
address comments
overvenus Dec 7, 2022
9df946b
Merge branch 'master' into span-replication/agent
overvenus Dec 7, 2022
a130d2a
generate protobuf
overvenus Dec 7, 2022
cd4991c
Merge branch 'master' into span-replication/agent
overvenus Dec 7, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions Makefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -242,6 +242,7 @@ fmt: tools/bin/gofumports tools/bin/shfmt tools/bin/gci
tools/bin/shfmt -d -w .
@echo "check log style"
scripts/check-log-style.sh
@make check-diff-line-width

errdoc: tools/bin/errdoc-gen
@echo "generator errors.toml"
Expand Down
2 changes: 1 addition & 1 deletion cdc/processor/manager.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -243,7 +243,7 @@ func (m *managerImpl) handleCommand(ctx cdcContext.Context) error {
case commandTpQueryTableCount:
count := 0
for _, p := range m.processors {
count += len(p.GetAllCurrentTables())
count += p.GetTableSpanCount()
}
select {
case cmd.payload.(chan int) <- count:
Expand Down
Loading