- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for Parallelism (0.2 sec)
-
pkg/scheduler/framework/parallelize/parallelism.go
) // DefaultParallelism is the default parallelism used in scheduler. const DefaultParallelism int = 16 // Parallelizer holds the parallelism for scheduler. type Parallelizer struct { parallelism int } // NewParallelizer returns an object holding the parallelism. func NewParallelizer(p int) Parallelizer { return Parallelizer{parallelism: p} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 17:12:30 UTC 2023 - 2K bytes - Viewed (0) -
pkg/api/job/warnings_test.go
}, wantWarningsCount: 1, }, "valid Indexed low completions low parallelism": { spec: &batch.JobSpec{ CompletionMode: completionModePtr(batch.IndexedCompletion), Completions: pointer.Int32(10_000), Parallelism: pointer.Int32(10_000), Template: validPodTemplate, }, }, "valid Indexed high completions low parallelism": { spec: &batch.JobSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 14:38:42 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/apis/batch/v1/defaults.go
// For a non-parallel job, you can leave both `.spec.completions` and // `.spec.parallelism` unset. When both are unset, both are defaulted to 1. if obj.Spec.Completions == nil && obj.Spec.Parallelism == nil { obj.Spec.Completions = utilpointer.Int32(1) obj.Spec.Parallelism = utilpointer.Int32(1) } if obj.Spec.Parallelism == nil { obj.Spec.Parallelism = utilpointer.Int32(1) } if obj.Spec.BackoffLimit == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 20:51:40 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/api/job/warnings.go
completions := ptr.Deref(spec.Completions, 0) parallelism := ptr.Deref(spec.Parallelism, 0) if completions > completionsSoftLimit && parallelism > parallelismSoftLimitForUnlimitedCompletions { msg := "In Indexed Jobs with a number of completions higher than 10^5 and a parallelism higher than 10^4, Kubernetes might not be able to track completedIndexes when a big number of indexes fail"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 24 11:44:07 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/apis/batch/fuzzer/fuzzer.go
func(j *batch.JobSpec, c fuzz.Continue) { c.FuzzNoCustom(j) // fuzz self without calling this function again completions := int32(c.Rand.Int31()) parallelism := int32(c.Rand.Int31()) backoffLimit := int32(c.Rand.Int31()) j.Completions = &completions j.Parallelism = ¶llelism j.BackoffLimit = &backoffLimit j.ManualSelector = pointer.Bool(c.RandBool()) mode := batch.NonIndexedCompletion if c.RandBool() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 17:25:15 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/converter/StartParameterConverterTest.groovy
def parameter = convert() parameter.logLevel == LogLevel.DEBUG } def "can provide parallelism option as command-line option"() { expect: def parameter = convert("--max-workers", "123") parameter.maxWorkerCount == 123 } def "can provide parallelism option as system property on command-line"() { expect: def parameter = convert("-Dorg.gradle.workers.max=123")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/batch/v1/jobspec.go
} // WithParallelism sets the Parallelism field in the declarative configuration to the given value // and returns the receiver, so that objects can be built by chaining "With" function invocations. // If called multiple times, the Parallelism field is set to the value of the last call. func (b *JobSpecApplyConfiguration) WithParallelism(value int32) *JobSpecApplyConfiguration { b.Parallelism = &value return b }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 20:49:09 UTC 2024 - 9.6K bytes - Viewed (0) -
src/embed/internal/embedtest/concurrency.txt
Concurrency is not parallelism....
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 29 16:26:43 UTC 2020 - 32 bytes - Viewed (0) -
src/embed/internal/embedtest/embedx_test.go
testFiles(t, global, "testdata/hello.txt", "hello, world\n") testString(t, concurrency, "concurrency", "Concurrency is not parallelism.\n") testString(t, string(glass), "glass", "I can eat glass and it doesn't hurt me.\n") testString(t, concurrency2, "concurrency2", "Concurrency is not parallelism.\n") testString(t, string(glass2), "glass2", "I can eat glass and it doesn't hurt me.\n") big, err := os.ReadFile("testdata/ascii.txt")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jan 15 20:37:17 UTC 2021 - 2.1K bytes - Viewed (0) -
src/cmd/go/testdata/script/mod_replace.txt
# Modules can be replaced by local packages. cp go.mod.orig go.mod go mod edit -replace=rsc.io/quote/v3=./local/rsc.io/quote/v3 go build -o a2.exe . exec ./a2.exe stdout 'Concurrency is not parallelism.' # The module path of the replacement doesn't need to match. # (For example, it could be a long-running fork with its own import path.) cp go.mod.orig go.mod
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 28 17:19:14 UTC 2021 - 3.7K bytes - Viewed (0)