check io copy error

oceanbase · Mar 13, 2024 · ba16178 · ba16178
1 parent 499a186
commit ba16178
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/internal/resource/utils/util.go b/internal/resource/utils/util.go
@@ -263,7 +263,10 @@ func RunJob(c client.Client, logger *logr.Logger, namespace string, jobName stri
 			logger.Error(err, "failed to get job logs")
 		} else {
 			defer logs.Close()
-			io.Copy(&outputBuffer, logs)
+			_, err = io.Copy(&outputBuffer, logs)
+			if err != nil {
+				logger.Error(err, "failed to copy logs")
+			}
 			output = outputBuffer.String()
 		}
 	} else {