diff --git a/executor/internal/mpp/local_mpp_coordinator.go b/executor/internal/mpp/local_mpp_coordinator.go index 84f969d5b4f5b..8251a732b313b 100644 --- a/executor/internal/mpp/local_mpp_coordinator.go +++ b/executor/internal/mpp/local_mpp_coordinator.go @@ -229,7 +229,6 @@ func (c *localMppCoordinator) appendMPPDispatchReq(pf *plannercore.Fragment) err CoordinatorAddress: c.coordinatorAddr, ReportExecutionSummary: c.reportExecutionInfo, State: kv.MppTaskReady, - ResourceGroupName: c.sessionCtx.GetSessionVars().ResourceGroupName, } c.reqMap[req.ID] = &mppRequestReport{mppReq: req, receivedReport: false, errMsg: "", executionSummaries: nil} c.mppReqs = append(c.mppReqs, req) diff --git a/kv/mpp.go b/kv/mpp.go index 402309fd61619..214528086365d 100644 --- a/kv/mpp.go +++ b/kv/mpp.go @@ -154,7 +154,6 @@ type MPPDispatchRequest struct { CoordinatorAddress string ReportExecutionSummary bool State MppTaskStates - ResourceGroupName string } // CancelMPPTasksParam represents parameter for MPPClient's CancelMPPTasks diff --git a/store/copr/batch_coprocessor.go b/store/copr/batch_coprocessor.go index 1ae43c14de221..02a2bd77784eb 100644 --- a/store/copr/batch_coprocessor.go +++ b/store/copr/batch_coprocessor.go @@ -1276,9 +1276,6 @@ func (b *batchCopIterator) handleTaskOnce(ctx context.Context, bo *backoff.Backo RecordTimeStat: true, RecordScanStat: true, TaskId: b.req.TaskID, - ResourceControlContext: &kvrpcpb.ResourceControlContext{ - ResourceGroupName: b.req.ResourceGroupName, - }, }) if b.req.ResourceGroupTagger != nil { b.req.ResourceGroupTagger(req) diff --git a/store/copr/mpp.go b/store/copr/mpp.go index 513a115168839..945252a130340 100644 --- a/store/copr/mpp.go +++ b/store/copr/mpp.go @@ -108,7 +108,6 @@ func (c *MPPClient) DispatchMPPTask(param kv.DispatchMPPTaskParam) (resp *mpp.Di CoordinatorAddress: req.CoordinatorAddress, ReportExecutionSummary: req.ReportExecutionSummary, MppVersion: req.MppVersion.ToInt64(), - ResourceGroupName: req.ResourceGroupName, } mppReq := &mpp.DispatchTaskRequest{