Skip to content

Commit

Permalink
Reverted non related log changes
Browse files Browse the repository at this point in the history
  • Loading branch information
mjonss committed Jan 20, 2023
1 parent b5a74c3 commit 0cb356f
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions ddl/reorg.go
Original file line number Diff line number Diff line change
Expand Up @@ -569,12 +569,12 @@ func getTableRange(ctx *JobContext, d *ddlCtx, tbl table.PhysicalTable, snapshot
endHandleKey = tablecodec.EncodeRecordKey(tbl.RecordPrefix(), maxHandle)
}
if isEmptyTable || endHandleKey.Cmp(startHandleKey) < 0 {
logutil.BgLogger().Info("[ddl] get table range, endHandle < startHandle",
logutil.BgLogger().Info("[ddl] get noop table range",
zap.String("table", fmt.Sprintf("%v", tbl.Meta())),
zap.Int64("table/partition ID", tbl.GetPhysicalID()),
zap.Bool("isEmptyTable", isEmptyTable),
zap.String("endHandle", hex.EncodeToString(endHandleKey)),
zap.String("startHandle", hex.EncodeToString(startHandleKey)))
zap.String("start key", hex.EncodeToString(startHandleKey)),
zap.String("end key", hex.EncodeToString(endHandleKey)),
zap.Bool("is empty table", isEmptyTable))
endHandleKey = startHandleKey
}
return
Expand Down Expand Up @@ -710,6 +710,7 @@ func getReorgInfoFromPartitions(ctx *JobContext, d *ddlCtx, rh *reorgHandler, jo
}
pid = partitionIDs[0]
physTbl := tbl.GetPartition(pid)

start, end, err = getTableRange(ctx, d, physTbl, ver.Ver, job.Priority)
if err != nil {
return nil, errors.Trace(err)
Expand Down

0 comments on commit 0cb356f

Please sign in to comment.