From 41518feb0a60097843d11e793c6e0b3d86c86c40 Mon Sep 17 00:00:00 2001 From: Wojciech Tyczynski Date: Thu, 1 Sep 2016 14:27:25 +0200 Subject: [PATCH] Fix TestServiceAlloc flake --- test/integration/master/master_test.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/test/integration/master/master_test.go b/test/integration/master/master_test.go index f1e80fe2388..51a24978a46 100644 --- a/test/integration/master/master_test.go +++ b/test/integration/master/master_test.go @@ -32,6 +32,7 @@ import ( "github.com/ghodss/yaml" "k8s.io/kubernetes/pkg/api" + "k8s.io/kubernetes/pkg/api/errors" "k8s.io/kubernetes/pkg/api/testapi" "k8s.io/kubernetes/pkg/apis/batch/v2alpha1" "k8s.io/kubernetes/pkg/client/restclient" @@ -442,6 +443,17 @@ func TestServiceAlloc(t *testing.T) { } } + // Wait until the default "kubernetes" service is created. + if err = wait.Poll(250*time.Millisecond, time.Minute, func() (bool, error) { + _, err := client.Services(api.NamespaceDefault).Get("kubernetes") + if err != nil && !errors.IsNotFound(err) { + return false, err + } + return !errors.IsNotFound(err), nil + }); err != nil { + t.Fatalf("creating kubernetes service timed out") + } + // Make a service. if _, err := client.Services(api.NamespaceDefault).Create(svc(1)); err != nil { t.Fatalf("got unexpected error: %v", err)