diff --git a/contrib/mesos/pkg/scheduler/service/service.go b/contrib/mesos/pkg/scheduler/service/service.go index 0e8c556eeb..a58f00a29b 100644 --- a/contrib/mesos/pkg/scheduler/service/service.go +++ b/contrib/mesos/pkg/scheduler/service/service.go @@ -160,9 +160,11 @@ func NewSchedulerServer() *SchedulerServer { Address: util.IP(net.ParseIP("127.0.0.1")), FailoverTimeout: time.Duration((1 << 62) - 1).Seconds(), - RunProxy: true, - ExecutorSuicideTimeout: execcfg.DefaultSuicideTimeout, - ExecutorCgroupPrefix: execcfg.DefaultCgroupPrefix, + RunProxy: true, + ExecutorSuicideTimeout: execcfg.DefaultSuicideTimeout, + ExecutorCgroupPrefix: execcfg.DefaultCgroupPrefix, + DefaultContainerCPULimit: mresource.DefaultDefaultContainerCPULimit, + DefaultContainerMemLimit: mresource.DefaultDefaultContainerMemLimit, MinionLogMaxSize: minioncfg.DefaultLogMaxSize(), MinionLogMaxBackups: minioncfg.DefaultLogMaxBackups, diff --git a/contrib/mesos/pkg/scheduler/service/service_test.go b/contrib/mesos/pkg/scheduler/service/service_test.go index e329e89334..7894074554 100644 --- a/contrib/mesos/pkg/scheduler/service/service_test.go +++ b/contrib/mesos/pkg/scheduler/service/service_test.go @@ -28,6 +28,8 @@ import ( "time" "github.com/GoogleCloudPlatform/kubernetes/contrib/mesos/pkg/archive" + mresource "github.com/GoogleCloudPlatform/kubernetes/contrib/mesos/pkg/scheduler/resource" + "github.com/stretchr/testify/assert" ) @@ -115,6 +117,14 @@ func Test_awaitFailoverDoneFailover(t *testing.T) { } } +func Test_DefaultResourceLimits(t *testing.T) { + assert := assert.New(t) + + s := NewSchedulerServer() + assert.Equal(s.DefaultContainerCPULimit, mresource.DefaultDefaultContainerCPULimit) + assert.Equal(s.DefaultContainerMemLimit, mresource.DefaultDefaultContainerMemLimit) +} + func Test_StaticPods(t *testing.T) { assert := assert.New(t)