add logging

Author: leoluoInSea

pkg/controller/flink/client/api.go

@@ -215,6 +215,8 @@ func (c *FlinkJobManagerClient) ForceCancelJob(ctx context.Context, url string,
 	url = url + path + "?mode=cancel"
 
 	response, err := c.executeRequest(ctx, httpPatch, url, nil)
+	logger.Info(ctx, "response is ", response)
+	logger.Info(ctx, "err is ", err)
 	if err != nil {
 		c.metrics.forceCancelJobFailureCounter.Inc(ctx)
 		logger.Errorf(ctx, fmt.Sprintf("Force cancel job failed with error %v", err))
@@ -225,7 +227,7 @@ func (c *FlinkJobManagerClient) ForceCancelJob(ctx context.Context, url string,
 		logger.Errorf(ctx, fmt.Sprintf("Force cancel job failed with response %v", response))
 		return GetRetryableError(err, v1beta1.ForceCancelJob, response.Status(), DefaultRetries)
 	}
-
+	logger.Info(ctx, "Successfully cancelled the job")
 	c.metrics.forceCancelJobSuccessCounter.Inc(ctx)
 	return nil
 }

pkg/controller/flinkapplication/flink_state_machine.go

@@ -984,6 +984,7 @@ func (s *FlinkStateMachine) handleApplicationDeleting(ctx context.Context, app *
 	}
 	job, err := s.flinkController.GetJobForApplication(ctx, app, app.Status.DeployHash)
 	if err != nil {
+		logger.Warn(ctx, "Error: "+err.Error(), err)
 		return statusUnchanged, err
 	}
 
@@ -995,6 +996,7 @@ func (s *FlinkStateMachine) handleApplicationDeleting(ctx context.Context, app *
 	case v1beta1.DeleteModeForceCancel:
 		if job.State == client.Cancelling {
 			// we've already cancelled the job, waiting for it to finish
+			logger.Info(ctx, "Still in cancelling..")
 			return statusUnchanged, nil
 		} else if jobFinished(job) {
 			// job was successfully cancelled