diff --git a/cmd/integration/integration.go b/cmd/integration/integration.go index 00fd9900a98..5e5838aa71d 100644 --- a/cmd/integration/integration.go +++ b/cmd/integration/integration.go @@ -994,10 +994,22 @@ func main() { // Wait for the synchronization threads to come up. time.Sleep(time.Second * 10) - kubeClient := client.NewOrDie(&restclient.Config{Host: apiServerURL, ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Default.GroupVersion()}}) + kubeClient := client.NewOrDie( + &restclient.Config{ + Host: apiServerURL, + ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Default.GroupVersion()}, + QPS: 20, + Burst: 50, + }) // TODO: caesarxuchao: hacky way to specify version of Experimental client. // We will fix this by supporting multiple group versions in Config - kubeClient.ExtensionsClient = client.NewExtensionsOrDie(&restclient.Config{Host: apiServerURL, ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Extensions.GroupVersion()}}) + kubeClient.ExtensionsClient = client.NewExtensionsOrDie( + &restclient.Config{ + Host: apiServerURL, + ContentConfig: restclient.ContentConfig{GroupVersion: testapi.Extensions.GroupVersion()}, + QPS: 20, + Burst: 50, + }) // Run tests in parallel testFuncs := []testFunc{ diff --git a/test/e2e/density.go b/test/e2e/density.go index 6c989506662..03cbc6e78df 100644 --- a/test/e2e/density.go +++ b/test/e2e/density.go @@ -144,12 +144,8 @@ var _ = Describe("Density", func() { }) // Explicitly put here, to delete namespace at the end of the test - // (after measuring latency metrics, etc.).framework := NewFramework("density") - options := FrameworkOptions{ - clientQPS: 20, - clientBurst: 30, - } - framework := NewFramework("density", options) + // (after measuring latency metrics, etc.). + framework := NewDefaultFramework("density") framework.NamespaceDeletionTimeout = time.Hour BeforeEach(func() { diff --git a/test/e2e/framework.go b/test/e2e/framework.go index 236aa8e324a..7a9749c2c95 100644 --- a/test/e2e/framework.go +++ b/test/e2e/framework.go @@ -84,8 +84,8 @@ type FrameworkOptions struct { // you (you can write additional before/after each functions). func NewDefaultFramework(baseName string) *Framework { options := FrameworkOptions{ - clientQPS: 5, - clientBurst: 10, + clientQPS: 20, + clientBurst: 50, } return NewFramework(baseName, options) }