diff --git a/pkg/controller/replication_controller.go b/pkg/controller/replication_controller.go index 49c026b8681..b347d94c72c 100644 --- a/pkg/controller/replication_controller.go +++ b/pkg/controller/replication_controller.go @@ -21,9 +21,11 @@ import ( "time" "github.com/GoogleCloudPlatform/kubernetes/pkg/api" + "github.com/GoogleCloudPlatform/kubernetes/pkg/api/errors" "github.com/GoogleCloudPlatform/kubernetes/pkg/client" "github.com/GoogleCloudPlatform/kubernetes/pkg/labels" "github.com/GoogleCloudPlatform/kubernetes/pkg/util" + "github.com/GoogleCloudPlatform/kubernetes/pkg/watch" "github.com/golang/glog" ) @@ -122,6 +124,10 @@ func (rm *ReplicationManager) watchControllers(resourceVersion *string) { // that called us call us again. return } + if event.Type == watch.Error { + glog.Errorf("error from watch during sync: %v", errors.FromObject(event.Object)) + continue + } glog.V(4).Infof("Got watch: %#v", event) rc, ok := event.Object.(*api.ReplicationController) if !ok {