diff --git a/planner/core/planbuilder.go b/planner/core/planbuilder.go
index f54675f142d74..28f7b25dbf1fa 100644
--- a/planner/core/planbuilder.go
+++ b/planner/core/planbuilder.go
@@ -227,6 +227,8 @@ func (b *PlanBuilder) buildDo(v *ast.DoStmt) (Plan, error) {
 			RetType:  expr.GetType(),
 		})
 	}
+	//make dual schema if not
+	var _ = dual.Schema()
 	p.SetChildren(dual)
 	p.self = p
 	p.SetSchema(schema)