Skip to content

Commit

Permalink
remove unused field
Browse files Browse the repository at this point in the history
Signed-off-by: lance6716 <lance6716@gmail.com>
  • Loading branch information
lance6716 committed Apr 15, 2023
1 parent 02d39eb commit 313c84a
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
2 changes: 1 addition & 1 deletion br/pkg/lightning/backend/local/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ go_test(
embed = [":local"],
flaky = True,
race = "on",
shard_count = 48,
shard_count = 49,
deps = [
"//br/pkg/lightning/backend",
"//br/pkg/lightning/backend/encode",
Expand Down
3 changes: 0 additions & 3 deletions br/pkg/lightning/backend/local/local_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -687,7 +687,6 @@ type mockImportClient struct {
cnt int
multiIngestCheckFn func(s *metapb.Store) bool
apiInvokeRecorder map[string][]uint64
wrote bool
}

func newMockImportClient() *mockImportClient {
Expand All @@ -704,7 +703,6 @@ func (c *mockImportClient) MultiIngest(_ context.Context, req *sst.MultiIngestRe
}()
for _, meta := range req.Ssts {
if meta.RegionId != c.store.GetId() {
println("lance test mismatch", meta.RegionId, c.store.GetId())
return &sst.IngestResponse{Error: &errorpb.Error{Message: "The file which would be ingested doest not exist."}}, nil
}
}
Expand Down Expand Up @@ -738,7 +736,6 @@ func (c *mockImportClient) Write(ctx context.Context, opts ...grpc.CallOption) (
if c.apiInvokeRecorder != nil {
c.apiInvokeRecorder["Write"] = append(c.apiInvokeRecorder["Write"], c.store.GetId())
}
c.wrote = true
return mockWriteClient{writeResp: &sst.WriteResponse{Metas: []*sst.SSTMeta{
{RegionId: c.store.GetId()},
}}}, nil
Expand Down

0 comments on commit 313c84a

Please sign in to comment.