From 76f4503f08413d48f25b7e5f8b205ed1160451ad Mon Sep 17 00:00:00 2001 From: hehechen Date: Fri, 18 Nov 2022 17:52:39 +0800 Subject: [PATCH] add log when available changed Signed-off-by: hehechen --- ddl/table.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/ddl/table.go b/ddl/table.go index df329fd973c06..a6e2d93b5ac7e 100644 --- a/ddl/table.go +++ b/ddl/table.go @@ -1341,6 +1341,7 @@ func onUpdateFlashReplicaStatus(d *ddlCtx, t *meta.Meta, job *model.Job) (ver in newIDs = append(newIDs, tblInfo.TiFlashReplica.AvailablePartitionIDs[i+1:]...) tblInfo.TiFlashReplica.AvailablePartitionIDs = newIDs tblInfo.TiFlashReplica.Available = false + logutil.BgLogger().Info("TiFlash replica become unavailable", zap.Int64("tableID", tblInfo.ID), zap.Int64("partitionID", id)) break } } @@ -1350,6 +1351,9 @@ func onUpdateFlashReplicaStatus(d *ddlCtx, t *meta.Meta, job *model.Job) (ver in return ver, errors.Errorf("unknown physical ID %v in table %v", physicalID, tblInfo.Name.O) } + if tblInfo.TiFlashReplica.Available { + logutil.BgLogger().Info("TiFlash replica available", zap.Int64("tableID", tblInfo.ID)) + } ver, err = updateVersionAndTableInfo(d, t, job, tblInfo, true) if err != nil { return ver, errors.Trace(err)