Skip to content

Commit

Permalink
kv (ticdc): fix kvClient reconnection downhill loop (#10559)
Browse files Browse the repository at this point in the history
close #10239
  • Loading branch information
asddongmen authored Jan 31, 2024
1 parent 0b88e5f commit 98adc64
Show file tree
Hide file tree
Showing 5 changed files with 342 additions and 222 deletions.
4 changes: 0 additions & 4 deletions cdc/entry/schema_test_helper.go
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

0 comments on commit 98adc64

Please sign in to comment.