diff --git a/systest/cluster/nodes.go b/systest/cluster/nodes.go index db1afa90df..aca5764a1e 100644 --- a/systest/cluster/nodes.go +++ b/systest/cluster/nodes.go @@ -62,12 +62,12 @@ var ( "requests and limits for smesher container", &apiv1.ResourceRequirements{ Requests: apiv1.ResourceList{ - apiv1.ResourceCPU: resource.MustParse("0.4"), - apiv1.ResourceMemory: resource.MustParse("400Mi"), + apiv1.ResourceCPU: resource.MustParse("1.3"), + apiv1.ResourceMemory: resource.MustParse("800Mi"), }, Limits: apiv1.ResourceList{ - apiv1.ResourceCPU: resource.MustParse("2"), - apiv1.ResourceMemory: resource.MustParse("1Gi"), + apiv1.ResourceCPU: resource.MustParse("1.3"), + apiv1.ResourceMemory: resource.MustParse("800Mi"), }, }, toResources, @@ -92,11 +92,11 @@ var ( "requests and limits for poet container", &apiv1.ResourceRequirements{ Requests: apiv1.ResourceList{ - apiv1.ResourceCPU: resource.MustParse("0.5"), + apiv1.ResourceCPU: resource.MustParse("0.4"), apiv1.ResourceMemory: resource.MustParse("1Gi"), }, Limits: apiv1.ResourceList{ - apiv1.ResourceCPU: resource.MustParse("0.5"), + apiv1.ResourceCPU: resource.MustParse("0.4"), apiv1.ResourceMemory: resource.MustParse("1Gi"), }, }, diff --git a/systest/testcontext/context.go b/systest/testcontext/context.go index 502a206d83..e06d99cb57 100644 --- a/systest/testcontext/context.go +++ b/systest/testcontext/context.go @@ -24,6 +24,7 @@ import ( corev1 "k8s.io/client-go/applyconfigurations/core/v1" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" + "k8s.io/client-go/util/flowcontrol" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/log" k8szap "sigs.k8s.io/controller-runtime/pkg/log/zap" @@ -288,6 +289,9 @@ func New(t *testing.T, opts ...Opt) *Context { t.Cleanup(func() { <-tokens }) } config, err := rest.InClusterConfig() + + // The default rate limiter is too slow 5qps and 10 burst, This will prevent the client from being throttled + config.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(20, 50) require.NoError(t, err) clientset, err := kubernetes.NewForConfig(config)