diff --git a/internal/locate/region_request_test.go b/internal/locate/region_request_test.go index 8e10e30b8..c43aecb08 100644 --- a/internal/locate/region_request_test.go +++ b/internal/locate/region_request_test.go @@ -582,6 +582,10 @@ func (s *mockTikvGrpcServer) GetHealthFeedback(ctx context.Context, request *kvr return nil, errors.New("unreachable") } +func (s *mockTikvGrpcServer) BroadcastTxnStatus(ctx context.Context, request *kvrpcpb.BroadcastTxnStatusRequest) (*kvrpcpb.BroadcastTxnStatusResponse, error) { + return nil, errors.New("unreachable") +} + func (s *testRegionRequestToSingleStoreSuite) TestNoReloadRegionForGrpcWhenCtxCanceled() { // prepare a mock tikv grpc server addr := "localhost:56341" diff --git a/tikv/kv_test.go b/tikv/kv_test.go index c2e4631e2..1a9a4618f 100644 --- a/tikv/kv_test.go +++ b/tikv/kv_test.go @@ -51,7 +51,6 @@ type testKVSuite struct { func (s *testKVSuite) SetupTest() { client, cluster, pdClient, err := testutils.NewMockTiKV("", nil) s.Require().Nil(err) - testutils.BootstrapWithSingleStore(cluster) s.setGetMinResolvedTSByStoresIDs(func(ctx context.Context, ids []uint64) (uint64, map[uint64]uint64, error) { return 0, nil, nil })