Skip to content

Commit f4ca082

Browse files
authored
ddl: use a param to decide whether exec in distributed mode (#41549) (#41554)
ref #41534
1 parent b086085 commit f4ca082

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

ddl/backfilling.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -211,8 +211,8 @@ type backfillCtx struct {
211211
}
212212

213213
func newBackfillCtx(ctx *ddlCtx, id int, sessCtx sessionctx.Context, reorgTp model.ReorgType,
214-
schemaName string, tbl table.Table) *backfillCtx {
215-
if id == 0 {
214+
schemaName string, tbl table.Table, isDistributed bool) *backfillCtx {
215+
if isDistributed {
216216
id = int(backfillContextID.Add(1))
217217
}
218218
return &backfillCtx{
@@ -912,7 +912,7 @@ func (b *backfillScheduler) adjustWorkerSize() error {
912912
)
913913
switch b.tp {
914914
case typeAddIndexWorker:
915-
backfillCtx := newBackfillCtx(reorgInfo.d, i, sessCtx, reorgInfo.ReorgMeta.ReorgTp, job.SchemaName, b.tbl)
915+
backfillCtx := newBackfillCtx(reorgInfo.d, i, sessCtx, reorgInfo.ReorgMeta.ReorgTp, job.SchemaName, b.tbl, false)
916916
idxWorker, err := newAddIndexWorker(b.decodeColMap, b.tbl, backfillCtx,
917917
jc, job.ID, reorgInfo.currElement.ID, reorgInfo.currElement.TypeKey)
918918
if err != nil {
@@ -925,7 +925,7 @@ func (b *backfillScheduler) adjustWorkerSize() error {
925925
runner = newBackfillWorker(jc.ddlJobCtx, idxWorker)
926926
worker = idxWorker
927927
case typeAddIndexMergeTmpWorker:
928-
backfillCtx := newBackfillCtx(reorgInfo.d, i, sessCtx, reorgInfo.ReorgMeta.ReorgTp, job.SchemaName, b.tbl)
928+
backfillCtx := newBackfillCtx(reorgInfo.d, i, sessCtx, reorgInfo.ReorgMeta.ReorgTp, job.SchemaName, b.tbl, false)
929929
tmpIdxWorker := newMergeTempIndexWorker(backfillCtx, i, b.tbl, reorgInfo.currElement.ID, jc)
930930
runner = newBackfillWorker(jc.ddlJobCtx, tmpIdxWorker)
931931
worker = tmpIdxWorker

ddl/column.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1172,7 +1172,7 @@ func newUpdateColumnWorker(sessCtx sessionctx.Context, id int, t table.PhysicalT
11721172
}
11731173
rowDecoder := decoder.NewRowDecoder(t, t.WritableCols(), decodeColMap)
11741174
return &updateColumnWorker{
1175-
backfillCtx: newBackfillCtx(reorgInfo.d, id, sessCtx, reorgInfo.ReorgMeta.ReorgTp, reorgInfo.SchemaName, t),
1175+
backfillCtx: newBackfillCtx(reorgInfo.d, id, sessCtx, reorgInfo.ReorgMeta.ReorgTp, reorgInfo.SchemaName, t, false),
11761176
oldColInfo: oldCol,
11771177
newColInfo: newCol,
11781178
metricCounter: metrics.BackfillTotalCounter.WithLabelValues(metrics.GenerateReorgLabel("update_col_rate", reorgInfo.SchemaName, t.Meta().Name.String())),

ddl/dist_backfilling.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ func newBackfillWorkerContext(d *ddl, schemaName string, tbl table.Table, worker
7474
}
7575

7676
var bf backfiller
77-
bf, err = bfFunc(newBackfillCtx(d.ddlCtx, 0, se, bfMeta.ReorgTp, schemaName, tbl))
77+
bf, err = bfFunc(newBackfillCtx(d.ddlCtx, 0, se, bfMeta.ReorgTp, schemaName, tbl, true))
7878
if err != nil {
7979
if canSkipError(jobID, len(bwCtx.backfillWorkers), err) {
8080
err = nil

ddl/index.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1976,7 +1976,7 @@ func newCleanUpIndexWorker(sessCtx sessionctx.Context, id int, t table.PhysicalT
19761976
}
19771977
return &cleanUpIndexWorker{
19781978
baseIndexWorker: baseIndexWorker{
1979-
backfillCtx: newBackfillCtx(reorgInfo.d, id, sessCtx, reorgInfo.ReorgMeta.ReorgTp, reorgInfo.SchemaName, t),
1979+
backfillCtx: newBackfillCtx(reorgInfo.d, id, sessCtx, reorgInfo.ReorgMeta.ReorgTp, reorgInfo.SchemaName, t, false),
19801980
indexes: indexes,
19811981
rowDecoder: rowDecoder,
19821982
defaultVals: make([]types.Datum, len(t.WritableCols())),

0 commit comments

Comments
 (0)