disttask: optimize metrics (pingcap#48663)

close pingcap#48592
ti-chi-bot · Nov 17, 2023 · 7471600 · 7471600
1 parent 23314d9
commit 7471600
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 493 deletions.
diff --git a/pkg/disttask/importinto/job.go b/pkg/disttask/importinto/job.go
@@ -29,6 +29,7 @@ import (
 	"github.com/pingcap/tidb/pkg/domain/infosync"
 	"github.com/pingcap/tidb/pkg/executor/importer"
 	"github.com/pingcap/tidb/pkg/kv"
+	"github.com/pingcap/tidb/pkg/metrics"
 	"github.com/pingcap/tidb/pkg/sessionctx"
 	"github.com/pingcap/tidb/pkg/util/dbterror/exeerrors"
 	"github.com/pingcap/tidb/pkg/util/logutil"
@@ -199,6 +200,8 @@ func (ti *DistImporter) SubmitTask(ctx context.Context) (int64, *proto.Task, err
 	if globalTask == nil {
 		return 0, nil, errors.Errorf("cannot find global task with ID %d", taskID)
 	}
+
+	metrics.UpdateMetricsForAddTask(globalTask)
 	// update logger with task id.
 	ti.jobID = jobID
 	ti.taskID = taskID