Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 3 additions & 6 deletions manager/searcher/searcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ type searcher struct{}
func New(pluginDir string) Searcher {
s, err := LoadPlugin(pluginDir)
if err != nil {
logger.Info("use default searcher")
logger.Warnf("use default searcher because of loading searcher plugin failed: %v", err)
return &searcher{}
}

Expand Down Expand Up @@ -257,11 +257,8 @@ func calculateMultiElementAffinityScore(dst, src string) float64 {
elementLen = math.Min(len(dstElements), len(srcElements))

// Maximum element length is 5.
if elementLen > maxElementLen {
elementLen = maxElementLen
}

for i := 0; i < elementLen; i++ {
elementLen = min(elementLen, maxElementLen)
for i := range elementLen {
if !strings.EqualFold(dstElements[i], srcElements[i]) {
break
}
Expand Down
4 changes: 2 additions & 2 deletions pkg/rpc/scheduler/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,10 +42,10 @@ import (

const (
// DefaultQPS is default qps of grpc server.
DefaultQPS = 20 * 1000
DefaultQPS = 1000

// DefaultBurst is default burst of grpc server.
DefaultBurst = 30 * 1000
DefaultBurst = 1000

// DefaultMaxConnectionIdle is default max connection idle of grpc keepalive.
DefaultMaxConnectionIdle = 10 * time.Minute
Expand Down
Loading