resetting current partitioning id when rebuilding the indexes

pingcap · Aug 29, 2024 · c2c629c · c2c629c
1 parent 3e4e738
commit c2c629c
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pkg/ddl/column.go b/pkg/ddl/column.go
@@ -529,6 +529,10 @@ func (w *worker) updateCurrentElement(t table.Table, reorgInfo *reorgInfo) error
 		if err != nil {
 			return errors.Trace(err)
 		}
+		if pt, ok := t.(table.PartitionedTable); ok {
+			// Restart from first partition
+			reorgInfo.PhysicalTableID = pt.Meta().Partition.Definitions[0].ID
+		}
 	}
 
 	currentVer, err := getValidCurrentVersion(reorgInfo.jobCtx.store)
@@ -583,6 +587,10 @@ func (w *worker) updateCurrentElement(t table.Table, reorgInfo *reorgInfo) error
 		if err != nil {
 			return errors.Trace(err)
 		}
+		if pt, ok := t.(table.PartitionedTable); ok {
+			// Restart from first partition
+			reorgInfo.PhysicalTableID = pt.Meta().Partition.Definitions[0].ID
+		}
 	}
 	return nil
 }