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

etcd_worker: batch etcd patch (#3277) #3389

Merged
merged 10 commits into from
Dec 20, 2021
Merged

etcd_worker: batch etcd patch (#3277) #3389

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
36dc613
etcd_worker: batch etcd patch (#3277)
asddongmen Nov 11, 2021
feeba8f
Merge branch 'release-5.3' into cherry-pick-3277-to-release-5.3
ti-chi-bot Dec 20, 2021
7bcb21d
Merge branch 'release-5.3' into cherry-pick-3277-to-release-5.3
asddongmen Dec 20, 2021
f252d50
*: fix go mod error
asddongmen Dec 20, 2021
36439aa
*: fix error
asddongmen Dec 20, 2021
300a6ad
CDC/etcd_worker: add rate limiter to limit EtcdWorker tick frequency …
ti-chi-bot Nov 4, 2021
ea04f44
batch (ticdc): add etcdTxnMaxOps to limit the ops number of an etcd t…
asddongmen Dec 3, 2021
7f6507b
etcd_worker: fix missed watch events caused by progress notifications…
liuzix Dec 14, 2021
d8c08eb
*: fix error
asddongmen Dec 20, 2021
7a963d4
Merge branch 'release-5.3' into cherry-pick-3277-to-release-5.3
ti-chi-bot Dec 20, 2021
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
Prev Previous commit
Next Next commit
*: fix go mod error
  • Loading branch information
@asddongmen
asddongmen committed Dec 20, 2021
commit f252d5072589c9f8a60f76b9ed425619c9badab1
2 changes: 1 addition & 1 deletion cdc/metrics.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import (
"github.com/pingcap/tiflow/cdc/kv"
"github.com/pingcap/tiflow/cdc/owner"
"github.com/pingcap/tiflow/cdc/processor"
tablepipeline "github.com/pingcap/ticdc/cdc/processor/pipeline"
tablepipeline "github.com/pingcap/tiflow/cdc/processor/pipeline"
"github.com/pingcap/tiflow/cdc/puller"
"github.com/pingcap/tiflow/cdc/sink"
"github.com/pingcap/tiflow/cdc/sorter/memory"
Expand Down
4 changes: 2 additions & 2 deletions pkg/orchestrator/batch.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,8 @@ package orchestrator

import (
"github.com/pingcap/errors"
cerrors "github.com/pingcap/ticdc/pkg/errors"
"github.com/pingcap/ticdc/pkg/orchestrator/util"
cerrors "github.com/pingcap/tiflow/pkg/errors"
"github.com/pingcap/tiflow/pkg/orchestrator/util"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion pkg/orchestrator/batch_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ import (
"fmt"
"testing"

"github.com/pingcap/ticdc/pkg/orchestrator/util"
"github.com/pingcap/tiflow/pkg/orchestrator/util"
"github.com/stretchr/testify/require"
)

Expand Down