Added an oomwatcher function to manager

google · Feb 19, 2015 · 0f8623a · 0f8623a
1 parent e542ff0
commit 0f8623a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/manager/manager.go b/manager/manager.go
@@ -634,7 +634,7 @@ func (self *manager) watchForNewOoms() error {
 	}
 	err = oomLog.StreamOoms(outStream)
 	if err != nil {
-		glog.Errorf("error streaming OOMs: %v", err)
+		return err
 	}
 	go func() {
 		for oomInstance := range outStream {