Add error log for ForceCancel job (#143)

lyft · Dec 12, 2019 · 437a1ad · 437a1ad
1 parent 4edffc5
commit 437a1ad
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/controller/flink/client/api.go b/pkg/controller/flink/client/api.go
@@ -211,6 +211,7 @@ func (c *FlinkJobManagerClient) ForceCancelJob(ctx context.Context, url string,
 	response, err := c.executeRequest(ctx, httpPatch, url, nil)
 	if err != nil {
 		c.metrics.forceCancelJobFailureCounter.Inc(ctx)
+		logger.Errorf(ctx, fmt.Sprintf("Force cancel job failed with error %v", err))
 		return GetRetryableError(err, v1beta1.ForceCancelJob, GlobalFailure, DefaultRetries)
 	}
 	if response != nil && !response.IsSuccess() {