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

kv (ticdc): fix kvClient reconnection downhill loop #10559

Merged
merged 14 commits into from
Jan 31, 2024
Merged

kv (ticdc): fix kvClient reconnection downhill loop #10559

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
87b86e4
fix kvClient reconnect loop
asddongmen Jan 29, 2024
5808788
add sleep to help debug
asddongmen Jan 29, 2024
dc035b2
fix panic
asddongmen Jan 29, 2024
f15445c
fix ut error
asddongmen Jan 29, 2024
11b8f3f
remove debug hard code
asddongmen Jan 29, 2024
85a6d11
resolve comments
asddongmen Jan 30, 2024
671a553
refine region worker
asddongmen Jan 30, 2024
ddcc321
add a time sleep to prevent stream delete frequency
asddongmen Jan 30, 2024
12025ce
fix panic
asddongmen Jan 30, 2024
5fb44f9
refine log
asddongmen Jan 30, 2024
e9a953d
prevent stream creation too frequent
asddongmen Jan 30, 2024
255e7df
fix error
asddongmen Jan 30, 2024
19612fb
fix ut error
asddongmen Jan 31, 2024
6aad55e
fix ut error 2
asddongmen Jan 31, 2024
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
4 changes: 0 additions & 4 deletions cdc/entry/schema_test_helper.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,11 @@ package entry

import (
"context"
"encoding/hex"
"encoding/json"
"strings"
"testing"
"time"

"github.com/pingcap/log"
ticonfig "github.com/pingcap/tidb/pkg/config"
tiddl "github.com/pingcap/tidb/pkg/ddl"
"github.com/pingcap/tidb/pkg/domain"
Expand All @@ -39,7 +37,6 @@ import (
"github.com/pingcap/tiflow/pkg/util"
"github.com/stretchr/testify/require"
"github.com/tikv/client-go/v2/oracle"
"go.uber.org/zap"
)

// SchemaTestHelper is a test helper for schema which creates an internal tidb instance to generate DDL jobs with meta information
Expand Down Expand Up @@ -197,7 +194,6 @@ func (s *SchemaTestHelper) DML2Event(dml string, schema, table string) *model.Ro
polymorphicEvent := model.NewPolymorphicEvent(rawKV)
err := s.mounter.DecodeEvent(context.Background(), polymorphicEvent)
require.NoError(s.t, err)
log.Info("fizz dml event", zap.String("key", hex.EncodeToString(polymorphicEvent.RawKV.Key)))
return polymorphicEvent.Row
}

Expand Down
Loading
Loading