From acb6a003793e79c5c0850b4a796c296185347211 Mon Sep 17 00:00:00 2001 From: wjhuang2016 Date: Wed, 31 May 2023 14:58:00 +0800 Subject: [PATCH] refine Signed-off-by: wjhuang2016 --- ddl/ddl_worker.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ddl/ddl_worker.go b/ddl/ddl_worker.go index a4038d83cc813..30782fa694985 100644 --- a/ddl/ddl_worker.go +++ b/ddl/ddl_worker.go @@ -481,14 +481,14 @@ func cleanMDLInfo(pool *sess.Pool, jobID int64, ec *clientv3.Client) { se.SetDiskFullOpt(kvrpcpb.DiskFullOpt_AllowedOnAlmostFull) _, err := se.Execute(context.Background(), sql, "delete-mdl-info") if err != nil { - logutil.BgLogger().Warn("unexpected error when clean mdl info", zap.Int64("job id", jobID), zap.Error(err)) + logutil.BgLogger().Warn("unexpected error when clean mdl info", zap.Int64("job ID", jobID), zap.Error(err)) return } if ec != nil { path := fmt.Sprintf("%s/%d/", util.DDLAllSchemaVersionsByJob, jobID) _, err = ec.Delete(context.Background(), path, clientv3.WithPrefix()) if err != nil { - logutil.BgLogger().Warn("[ddl] delete versions failed", zap.Int64("job id", jobID), zap.Error(err)) + logutil.BgLogger().Warn("[ddl] delete versions failed", zap.Int64("job ID", jobID), zap.Error(err)) } } }