From e2a08d443df1991d56d775013dd1f144c030148e Mon Sep 17 00:00:00 2001 From: xiongjiwei Date: Fri, 25 Nov 2022 14:07:47 +0800 Subject: [PATCH] fix build --- br/pkg/streamhelper/basic_lib_for_test.go | 4 ++++ domain/globalconfigsync/globalconfig_test.go | 1 + 2 files changed, 5 insertions(+) diff --git a/br/pkg/streamhelper/basic_lib_for_test.go b/br/pkg/streamhelper/basic_lib_for_test.go index 9e438c32f0f1f..b41d5baf19528 100644 --- a/br/pkg/streamhelper/basic_lib_for_test.go +++ b/br/pkg/streamhelper/basic_lib_for_test.go @@ -163,6 +163,10 @@ func (f *fakeStore) GetLastFlushTSOfRegion(ctx context.Context, in *logbackup.Ge return resp, nil } +func (f *fakeStore) SubscribeFlushEvent(ctx context.Context, in *logbackup.SubscribeFlushEventRequest, opts ...grpc.CallOption) (logbackup.LogBackup_SubscribeFlushEventClient, error) { + return nil, nil +} + // RegionScan gets a list of regions, starts from the region that contains key. // Limit limits the maximum number of regions returned. func (f *fakeCluster) RegionScan(ctx context.Context, key []byte, endKey []byte, limit int) ([]streamhelper.RegionWithLeader, error) { diff --git a/domain/globalconfigsync/globalconfig_test.go b/domain/globalconfigsync/globalconfig_test.go index f07e2e43983ec..d6013f2887693 100644 --- a/domain/globalconfigsync/globalconfig_test.go +++ b/domain/globalconfigsync/globalconfig_test.go @@ -87,6 +87,7 @@ func TestStoreGlobalConfig(t *testing.T) { require.NoError(t, err) _, err = se.Execute(context.Background(), "set @@global.tidb_enable_top_sql=1;") + require.NoError(t, err) _, err = se.Execute(context.Background(), "set @@global.tidb_source_id=2;") require.NoError(t, err) for i := 0; i < 20; i++ {