From ded8e03fc34ffff3c1196cb5f2dc5f33bc39cc41 Mon Sep 17 00:00:00 2001 From: gmarek Date: Thu, 25 May 2017 11:37:02 +0200 Subject: [PATCH] Reduce service creation/deletion parallelism in the load test --- test/e2e/framework/kubelet_stats.go | 1 - test/e2e/perf/load.go | 6 ++++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/test/e2e/framework/kubelet_stats.go b/test/e2e/framework/kubelet_stats.go index 9781b931173..d3a25a405c5 100644 --- a/test/e2e/framework/kubelet_stats.go +++ b/test/e2e/framework/kubelet_stats.go @@ -39,7 +39,6 @@ import ( "k8s.io/kubernetes/pkg/master/ports" "k8s.io/kubernetes/pkg/metrics" - "github.com/golang/glog" "github.com/prometheus/common/model" ) diff --git a/test/e2e/perf/load.go b/test/e2e/perf/load.go index 6f95c864c9e..0fd015cdc7a 100644 --- a/test/e2e/perf/load.go +++ b/test/e2e/perf/load.go @@ -59,6 +59,8 @@ const ( // nodeCountPerNamespace determines how many namespaces we will be using // depending on the number of nodes in the underlying cluster. nodeCountPerNamespace = 100 + // How many threads will be used to create/delete services during this test. + serviceOperationsParallelism = 5 ) var randomKind = schema.GroupKind{Kind: "Random"} @@ -190,7 +192,7 @@ var _ = framework.KubeDescribe("Load capacity", func() { _, err := clientset.Core().Services(services[i].Namespace).Create(services[i]) framework.ExpectNoError(err) } - workqueue.Parallelize(25, len(services), createService) + workqueue.Parallelize(serviceOperationsParallelism, len(services), createService) framework.Logf("%v Services created.", len(services)) defer func(services []*v1.Service) { framework.Logf("Starting to delete services...") @@ -198,7 +200,7 @@ var _ = framework.KubeDescribe("Load capacity", func() { err := clientset.Core().Services(services[i].Namespace).Delete(services[i].Name, nil) framework.ExpectNoError(err) } - workqueue.Parallelize(25, len(services), deleteService) + workqueue.Parallelize(serviceOperationsParallelism, len(services), deleteService) framework.Logf("Services deleted") }(services) } else {