Skip to content

Commit 3d380c4

Browse files
committed
update
Signed-off-by: Weizhen Wang <[email protected]>
1 parent 0b2312b commit 3d380c4

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

pkg/planner/core/exhaust_physical_plans.go

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1235,6 +1235,9 @@ func constructInnerIndexScanTask(
12351235
rowCount float64,
12361236
maxOneRow bool,
12371237
) base.Task {
1238+
if !p.SCtx().GetSessionVars().InRestrictedSQL {
1239+
fmt.Println("wwz")
1240+
}
12381241
ds := wrapper.ds
12391242
// If `ds.TableInfo.GetPartitionInfo() != nil`,
12401243
// it means the data source is a partition table reader.
@@ -1314,6 +1317,9 @@ func constructInnerIndexScanTask(
13141317
}
13151318
cop.tablePlan = ts
13161319
}
1320+
if !p.SCtx().GetSessionVars().InRestrictedSQL {
1321+
fmt.Println("wwz")
1322+
}
13171323
if cop.tablePlan != nil && ds.TableInfo.IsCommonHandle {
13181324
cop.commonHandleCols = ds.CommonHandleCols
13191325
}
@@ -2895,6 +2901,9 @@ func getHashAggs(lp base.LogicalPlan, prop *property.PhysicalProperty) []base.Ph
28952901
hashAggs = append(hashAggs, mppAggs...)
28962902
}
28972903
} else {
2904+
if !lp.SCtx().GetSessionVars().InRestrictedSQL {
2905+
fmt.Println("wwz")
2906+
}
28982907
agg := NewPhysicalHashAgg(la, la.StatsInfo().ScaleByExpectCnt(prop.ExpectedCnt), &property.PhysicalProperty{ExpectedCnt: math.MaxFloat64, TaskTp: taskTp, CTEProducerStatus: prop.CTEProducerStatus})
28992908
agg.SetSchema(la.Schema().Clone())
29002909
hashAggs = append(hashAggs, agg)

0 commit comments

Comments
 (0)