update sql visitor

dataux · Jan 22, 2016 · 808dbe3 · 808dbe3
1 parent 02de1f8
commit 808dbe3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/frontends/mysqlfe/build.go b/frontends/mysqlfe/build.go
@@ -36,6 +36,7 @@ func BuildMySqlob(ctx *plan.Context) (*MySqlJob, error) {
 	// We are going to swap out a new distributed planner
 	b.TaskMaker = planner.TaskRunnersMaker
 	job := &MySqlJob{JobBuilder: &b}
+	b.Visitor = job
 
 	task, err := exec.BuildSqlJobVisitor(job, ctx)
 	taskRunner, ok := task.(exec.TaskRunner)