revert rg name req code

Signed-off-by: guo-shaoge <shaoge1994@163.com>
pingcap · Sep 19, 2023 · 5c1baca · 5c1baca
1 parent 0805306
commit 5c1baca
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 6 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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{