File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -209,8 +209,8 @@ func (p *PhysicalHashJoin) Attach2Task(tasks ...base.Task) base.Task {
209
209
if p .storeTp == kv .TiFlash {
210
210
return p .attach2TaskForTiFlash (tasks ... )
211
211
}
212
- lTask := tasks [0 ].ConvertToRootTask (p .SCtx ())
213
212
rTask := tasks [1 ].ConvertToRootTask (p .SCtx ())
213
+ lTask := tasks [0 ].ConvertToRootTask (p .SCtx ())
214
214
p .SetChildren (lTask .Plan (), rTask .Plan ())
215
215
task := & RootTask {}
216
216
task .SetPlan (p )
@@ -391,8 +391,8 @@ func (p *PhysicalHashJoin) convertPartitionKeysIfNeed(lTask, rTask *MppTask) (*M
391
391
}
392
392
393
393
func (p * PhysicalHashJoin ) attach2TaskForMpp (tasks ... base.Task ) base.Task {
394
- lTask , lok := tasks [0 ].(* MppTask )
395
394
rTask , rok := tasks [1 ].(* MppTask )
395
+ lTask , lok := tasks [0 ].(* MppTask )
396
396
if ! lok || ! rok {
397
397
return base .InvalidTask
398
398
}
@@ -499,8 +499,8 @@ func (p *PhysicalHashJoin) attach2TaskForMpp(tasks ...base.Task) base.Task {
499
499
}
500
500
501
501
func (p * PhysicalHashJoin ) attach2TaskForTiFlash (tasks ... base.Task ) base.Task {
502
- lTask , lok := tasks [0 ].(* CopTask )
503
502
rTask , rok := tasks [1 ].(* CopTask )
503
+ lTask , lok := tasks [0 ].(* CopTask )
504
504
if ! lok || ! rok {
505
505
return p .attach2TaskForMpp (tasks ... )
506
506
}
You can’t perform that action at this time.
0 commit comments