fix

executor/builder.go

@@ -211,7 +211,9 @@ func (b *executorBuilder) buildCancelDDLJobs(v *plannercore.CancelDDLJobs) Execu
 
 func (b *executorBuilder) buildChange(v *plannercore.Change) Executor {
 	return &ChangeExec{
-		Statement: v.Statement,
+		NodeType: v.NodeType,
+		State:    v.State,
+		NodeID:   v.NodeID,
 	}
 }
 

executor/change.go

@@ -18,7 +18,6 @@ import (
 	"strings"
 
 	"github.com/pingcap/errors"
-	"github.com/pingcap/parser/ast"
 	"github.com/pingcap/tidb-tools/tidb-binlog/node"
 	"github.com/pingcap/tidb/config"
 	"github.com/pingcap/tidb/util/chunk"
@@ -28,13 +27,14 @@ import (
 type ChangeExec struct {
 	baseExecutor
 
-	Statement *ast.ChangeStmt
+	NodeType string
+	State    string
+	NodeID   string
 }
 
 // Next implements the Executor Next interface.
 func (e *ChangeExec) Next(ctx context.Context, req *chunk.RecordBatch) error {
-	stmt := e.Statement
-	kind := strings.ToLower(stmt.NodeType)
+	kind := strings.ToLower(e.NodeType)
 	urls := config.GetGlobalConfig().Path
 	registry, err := createRegistry(urls)
 	if err != nil {
@@ -44,8 +44,8 @@ func (e *ChangeExec) Next(ctx context.Context, req *chunk.RecordBatch) error {
 	if err != nil {
 		return err
 	}
-	state := stmt.State
-	nodeID := stmt.NodeID
+	state := e.State
+	nodeID := e.NodeID
 	for _, n := range nodes {
 		if n.NodeID != nodeID {
 			continue

planner/core/common_plans.go

@@ -137,7 +137,9 @@ type CancelDDLJobs struct {
 type Change struct {
 	baseSchemaProducer
 
-	Statement *ast.ChangeStmt
+	NodeType string
+	State    string
+	NodeID   string
 }
 
 // Prepare represents prepare plan.

planner/core/planbuilder.go

@@ -224,7 +224,11 @@ func (b *PlanBuilder) Build(node ast.Node) (Plan, error) {
 }
 
 func (b *PlanBuilder) buildChange(v *ast.ChangeStmt) (Plan, error) {
-	exe := &Change{Statement: v}
+	exe := &Change{
+		NodeType: v.NodeType,
+		State:    v.State,
+		NodeID:   v.NodeID,
+	}
 	return exe, nil
 }