From 36d2dbb7b1a2bfba6d2dd2c01130fddd7bfd8d4e Mon Sep 17 00:00:00 2001 From: "Zhuomin(Charming) Liu" Date: Fri, 14 Feb 2020 15:27:45 +0800 Subject: [PATCH] planner: set the partition id to table id in DAG request (#14745) --- planner/core/plan_to_pb.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/planner/core/plan_to_pb.go b/planner/core/plan_to_pb.go index eeeaff32da4e9..341b936692158 100644 --- a/planner/core/plan_to_pb.go +++ b/planner/core/plan_to_pb.go @@ -95,6 +95,9 @@ func (p *PhysicalTableScan) ToPB(ctx sessionctx.Context) (*tipb.Executor, error) Columns: model.ColumnsToProto(p.Columns, p.Table.PKIsHandle), Desc: p.Desc, } + if p.isPartition { + tsExec.TableId = p.physicalTableID + } err := SetPBColumnsDefaultValue(ctx, tsExec.Columns, p.Columns) return &tipb.Executor{Tp: tipb.ExecType_TypeTableScan, TblScan: tsExec}, err } @@ -140,6 +143,9 @@ func (p *PhysicalIndexScan) ToPB(ctx sessionctx.Context) (*tipb.Executor, error) Columns: model.ColumnsToProto(columns, p.Table.PKIsHandle), Desc: p.Desc, } + if p.isPartition { + idxExec.TableId = p.physicalTableID + } unique := checkCoverIndex(p.Index, p.Ranges) idxExec.Unique = &unique return &tipb.Executor{Tp: tipb.ExecType_TypeIndexScan, IdxScan: idxExec}, nil