Adding corev1 scheme to Events (#821)

* Adding corev1 scheme * Adding error check * Adding error check
kubeflow · Sep 4, 2018 · 1a726c7 · 1a726c7
1 parent ed91105
commit 1a726c7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/cmd/tf-operator.v2/app/server.go b/cmd/tf-operator.v2/app/server.go
@@ -127,6 +127,9 @@ func Run(opt *options.ServerOption) error {
 
 	// Prepare event clients.
 	eventBroadcaster := record.NewBroadcaster()
+	if err = v1.AddToScheme(scheme.Scheme); err != nil {
+		return fmt.Errorf("CoreV1 Add Scheme failed: %v", err)
+	}
 	recorder := eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "tf-operator"})
 
 	rl := &resourcelock.EndpointsLock{

diff --git a/pkg/controller.v2/jobcontroller/pod.go b/pkg/controller.v2/jobcontroller/pod.go
@@ -98,7 +98,7 @@ func (jc *JobController) UpdatePod(old, cur interface{}) {
 		if job == nil {
 			return
 		}
-		logger.Infof("pod has a ControllerRef: %v, %v", curPod, oldPod)
+		logger.Debugf("pod has a ControllerRef: %v, %v", curPod, oldPod)
 		jobKey, err := controller.KeyFunc(job)
 		if err != nil {
 			return