Skip to content

Commit

Permalink
fix log
Browse files Browse the repository at this point in the history
Signed-off-by: zwwhdls <[email protected]>
  • Loading branch information
zwwhdls committed Sep 19, 2024
1 parent bbc94e5 commit 17ee01e
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pkg/controller/app_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ func NewAppController(client *k8sclient.K8sClient) *AppController {
}

func (a *AppController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error) {
appCtrlLog.V(1).Info("Receive pod %s %s", "name", request.Name, "namespace", request.Namespace)
appCtrlLog.V(1).Info("Receive pod", "name", request.Name, "namespace", request.Namespace)
pod, err := a.K8sClient.GetPod(ctx, request.Name, request.Namespace)
if err != nil && !k8serrors.IsNotFound(err) {
appCtrlLog.Error(err, "get pod error", "name", request.Name)
Expand Down
2 changes: 1 addition & 1 deletion pkg/controller/job_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,7 @@ func (m *JobController) Reconcile(ctx context.Context, request reconcile.Request

// if csi node not exist, or job should be recycled itself, delete it
if needRecycled || resource.IsJobShouldBeRecycled(job) {
jobCtrlLog.Info("recycle job %s", "name", job.Name)
jobCtrlLog.Info("recycle job", "name", job.Name)
err = m.DeleteJob(ctx, job.Name, job.Namespace)
if err != nil {
jobCtrlLog.Error(err, "delete job error", "name", job.Name)
Expand Down
2 changes: 1 addition & 1 deletion pkg/controller/pod_driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -1005,7 +1005,7 @@ func (p *PodDriver) newMountPod(ctx context.Context, pod *corev1.Pod, newPodName
return nil
})
if err == nil {
log.Info("start to umount: %s", "mountPath", sourcePath)
log.Info("start to umount", "mountPath", sourcePath)
_ = util.DoWithTimeout(ctx, defaultCheckoutTimeout, func() error {
util.UmountPath(ctx, sourcePath)
return nil
Expand Down
2 changes: 1 addition & 1 deletion pkg/webhook/handler/register.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ func Register(mgr manager.Manager, client *k8sclient.K8sClient) {
server.Register(SidecarPath, &webhook.Admission{Handler: NewSidecarHandler(client, false)})
webhookLog.Info("Registered webhook handler for sidecar", "path", SidecarPath)
server.Register(ServerlessPath, &webhook.Admission{Handler: NewSidecarHandler(client, true)})
webhookLog.Info("Registered webhook handler path %s for serverless", "path", ServerlessPath)
webhookLog.Info("Registered webhook handler path for serverless", "path", ServerlessPath)
if config.ValidatingWebhook {
server.Register(SecretPath, &webhook.Admission{Handler: NewSecretHandler(client)})
server.Register(PVPath, &webhook.Admission{Handler: NewPVHandler(client)})
Expand Down

0 comments on commit 17ee01e

Please sign in to comment.