Skip to content

Commit

Permalink
fix ci
Browse files Browse the repository at this point in the history
Signed-off-by: crazycs520 <crazycs520@gmail.com>
  • Loading branch information
crazycs520 committed Mar 14, 2024
1 parent fa859bb commit 71883b2
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 1 deletion.
1 change: 1 addition & 0 deletions pkg/server/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -190,6 +190,7 @@ go_test(
"//pkg/util/chunk",
"//pkg/util/context",
"//pkg/util/dbterror/exeerrors",
"//pkg/util/plancodec",
"//pkg/util/replayer",
"//pkg/util/sqlkiller",
"//pkg/util/syncutil",
Expand Down
1 change: 1 addition & 0 deletions pkg/store/copr/coprocessor.go
Original file line number Diff line number Diff line change
Expand Up @@ -1102,6 +1102,7 @@ func (it *copIterator) Next(ctx context.Context) (kv.ResultSubset, error) {

// HasUnconsumedCopRuntimeStats indicate whether has unconsumed CopRuntimeStats.
type HasUnconsumedCopRuntimeStats interface {
// CollectUnconsumedCopRuntimeStats returns unconsumed CopRuntimeStats.
CollectUnconsumedCopRuntimeStats() []*CopRuntimeStats
}

Expand Down
2 changes: 1 addition & 1 deletion pkg/store/mockstore/unistore/rpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ func (c *RPCClient) SendRequest(ctx context.Context, addr string, req *tikvrpc.R
}
})
failpoint.Inject("unistoreRPCSlowByInjestSleep", func(val failpoint.Value) {
time.Sleep(time.Duration(val.(int)) * time.Millisecond)
time.Sleep(time.Duration(val.(int) * int(time.Millisecond)))
failpoint.Return(tikvrpc.GenRegionErrorResp(req, &errorpb.Error{Message: "Deadline is exceeded"}))
})

Expand Down

0 comments on commit 71883b2

Please sign in to comment.