Skip to content

Commit a371eac

Browse files
committed
Remove unused failpoint.
1 parent 3b6f49f commit a371eac

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

pkg/planner/core/exhaust_physical_plans.go

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1107,11 +1107,6 @@ func buildIndexJoinInner2TableScan(
11071107
lastColMng = indexJoinResult.lastColManager
11081108
}
11091109
joins = make([]base.PhysicalPlan, 0, 3)
1110-
failpoint.Inject("MockOnlyEnableIndexHashJoin", func(val failpoint.Value) {
1111-
if val.(bool) && !p.SCtx().GetSessionVars().InRestrictedSQL {
1112-
failpoint.Return(constructIndexHashJoin(p, prop, outerIdx, innerTask, nil, keyOff2IdxOff, path, lastColMng))
1113-
}
1114-
})
11151110
joins = append(joins, constructIndexJoin(p, prop, outerIdx, innerTask, ranges, keyOff2IdxOff, path, lastColMng, true)...)
11161111
// We can reuse the `innerTask` here since index nested loop hash join
11171112
// do not need the inner child to promise the order.
@@ -1148,11 +1143,6 @@ func buildIndexJoinInner2IndexScan(
11481143
joins = make([]base.PhysicalPlan, 0, 3)
11491144
rangeInfo, maxOneRow := indexJoinPathGetRangeInfoAndMaxOneRow(p.SCtx(), outerJoinKeys, indexJoinResult)
11501145
innerTask := constructInnerIndexScanTask(p, prop, wrapper, indexJoinResult.chosenPath, indexJoinResult.chosenRanges.Range(), indexJoinResult.chosenRemained, indexJoinResult.idxOff2KeyOff, rangeInfo, false, false, avgInnerRowCnt, maxOneRow)
1151-
failpoint.Inject("MockOnlyEnableIndexHashJoin", func(val failpoint.Value) {
1152-
if val.(bool) && !p.SCtx().GetSessionVars().InRestrictedSQL && innerTask != nil {
1153-
failpoint.Return(constructIndexHashJoin(p, prop, outerIdx, innerTask, indexJoinResult.chosenRanges, keyOff2IdxOff, indexJoinResult.chosenPath, indexJoinResult.lastColManager))
1154-
}
1155-
})
11561146
if innerTask != nil {
11571147
joins = append(joins, constructIndexJoin(p, prop, outerIdx, innerTask, indexJoinResult.chosenRanges, keyOff2IdxOff, indexJoinResult.chosenPath, indexJoinResult.lastColManager, true)...)
11581148
// We can reuse the `innerTask` here since index nested loop hash join
@@ -2667,12 +2657,6 @@ func tryToGetMppHashJoin(super base.LogicalPlan, prop *property.PhysicalProperty
26672657
// If the hint is not figured, we will pick all candidates.
26682658
func exhaustPhysicalPlans4LogicalJoin(super base.LogicalPlan, prop *property.PhysicalProperty) ([]base.PhysicalPlan, bool, error) {
26692659
ge, p := base.GetGEAndLogicalOp[*logicalop.LogicalJoin](super)
2670-
failpoint.Inject("MockOnlyEnableIndexHashJoin", func(val failpoint.Value) {
2671-
if val.(bool) && !p.SCtx().GetSessionVars().InRestrictedSQL {
2672-
indexJoins, _ := tryToGetIndexJoin(p, prop)
2673-
failpoint.Return(indexJoins, true, nil)
2674-
}
2675-
})
26762660

26772661
if !isJoinHintSupportedInMPPMode(p.PreferJoinType) {
26782662
if hasMPPJoinHints(p.PreferJoinType) {

0 commit comments

Comments
 (0)