diff --git a/pkg/controller.v2/controller_pod.go b/pkg/controller.v2/controller_pod.go index 248fbad22e..98a39f5724 100644 --- a/pkg/controller.v2/controller_pod.go +++ b/pkg/controller.v2/controller_pod.go @@ -63,7 +63,7 @@ func (tc *TFJobController) reconcilePods( podSlices := getPodSlices(pods, replicas, loggerForReplica(tfjob, rt)) for index, podSlice := range podSlices { if len(podSlice) > 1 { - loggerForReplica(tfjob, rt).Warningf("We have to many pods for %s %d", rt, index) + loggerForReplica(tfjob, rt).Warningf("We have too many pods for %s %d", rt, index) // TODO(gaocegege): Kill some pods. } else if len(podSlice) == 0 { loggerForReplica(tfjob, rt).Infof("Need to create new pod: %s-%d", rt, index) diff --git a/pkg/controller.v2/controller_service.go b/pkg/controller.v2/controller_service.go index a6791cf31f..6383986d34 100644 --- a/pkg/controller.v2/controller_service.go +++ b/pkg/controller.v2/controller_service.go @@ -51,7 +51,7 @@ func (tc *TFJobController) reconcileServices( for index, serviceSlice := range serviceSlices { if len(serviceSlice) > 1 { - loggerForReplica(tfjob, rt).Warningf("We have to many services for %s %d", rt, index) + loggerForReplica(tfjob, rt).Warningf("We have too many services for %s %d", rt, index) // TODO(gaocegege): Kill some services. } else if len(serviceSlice) == 0 { loggerForReplica(tfjob, rt).Infof("need to create new service: %s-%d", rt, index)