diff --git a/pkg/apis/core/v1/types.go b/pkg/apis/core/v1/types.go index d0208c88..c5ae1dbf 100644 --- a/pkg/apis/core/v1/types.go +++ b/pkg/apis/core/v1/types.go @@ -351,7 +351,7 @@ type ( IdleTimeout *int `json:"idletimeout,omitempty"` // Maximum number of pods to be specialized which will serve requests - // This is optional. If not specified default value will be taken as 5 + // This is optional. If not specified default value will be taken as 500 Concurrency int `json:"concurrency,omitempty"` // RequestsPerPod indicates the maximum number of concurrent requests that can be served by a specialized pod diff --git a/pkg/crd/crdvalidations.go b/pkg/crd/crdvalidations.go index e2bde072..c1dd072e 100644 --- a/pkg/crd/crdvalidations.go +++ b/pkg/crd/crdvalidations.go @@ -47,7 +47,7 @@ var ( }, "concurrency": { Type: "integer", - Description: "Concurrency specifies the maximum number of pods that can be specialized concurrently to serve requests.\n This is optional. If not specified default value will be taken as 5", + Description: "Concurrency specifies the maximum number of pods that can be specialized concurrently to serve requests.\n This is optional. If not specified default value will be taken as 500", }, "requestsPerPod": { Type: "integer", diff --git a/pkg/executor/api.go b/pkg/executor/api.go index 99ceb4be..979ea316 100644 --- a/pkg/executor/api.go +++ b/pkg/executor/api.go @@ -59,7 +59,7 @@ func (executor *Executor) getServiceForFunctionAPI(w http.ResponseWriter, r *htt if t == fv1.ExecutorTypePoolmgr { concurrency := fn.Spec.Concurrency if concurrency == 0 { - concurrency = 5 + concurrency = 500 } requestsPerpod := fn.Spec.RequestsPerPod if requestsPerpod == 0 { diff --git a/pkg/fission-cli/cmd/function/create.go b/pkg/fission-cli/cmd/function/create.go index 621b78dd..58ffa0db 100644 --- a/pkg/fission-cli/cmd/function/create.go +++ b/pkg/fission-cli/cmd/function/create.go @@ -41,7 +41,7 @@ import ( const ( DEFAULT_MIN_SCALE = 1 DEFAULT_TARGET_CPU_PERCENTAGE = 80 - DEFAULT_CONCURRENCY = 5 + DEFAULT_CONCURRENCY = 500 ) type CreateSubCommand struct { diff --git a/pkg/fission-cli/flag/flag.go b/pkg/fission-cli/flag/flag.go index d782f3e8..65351491 100644 --- a/pkg/fission-cli/flag/flag.go +++ b/pkg/fission-cli/flag/flag.go @@ -110,7 +110,7 @@ var ( FnTestHeader = Flag{Type: StringSlice, Name: flagkey.FnTestHeader, Short: "H", Usage: "Request headers"} FnTestQuery = Flag{Type: StringSlice, Name: flagkey.FnTestQuery, Short: "q", Usage: "Request query parameters: -q key1=value1 -q key2=value2"} FnIdleTimeout = Flag{Type: Int, Name: flagkey.FnIdleTimeout, Usage: "The length of time (in seconds) that a function is idle before pod(s) are eligible for recycling", DefaultValue: 120} - FnConcurrency = Flag{Type: Int, Name: flagkey.FnConcurrency, Aliases: []string{"con"}, Usage: "Maximum number of pods specialized concurrently to serve requests", DefaultValue: 5} + FnConcurrency = Flag{Type: Int, Name: flagkey.FnConcurrency, Aliases: []string{"con"}, Usage: "Maximum number of pods specialized concurrently to serve requests", DefaultValue: 500} FnRequestsPerPod = Flag{Type: Int, Name: flagkey.FnRequestsPerPod, Aliases: []string{"rpp"}, Usage: "Maximum number of concurrent requests that can be served by a specialized pod", DefaultValue: 1} HtName = Flag{Type: String, Name: flagkey.HtName, Usage: "HTTP trigger name"}