executor: address comments

zimulala · Oct 25, 2018 · 361a41d · 361a41d
1 parent 1162a3f
commit 361a41d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/executor/ddl.go b/executor/ddl.go
@@ -68,8 +68,8 @@ func (e *DDLExec) Next(ctx context.Context, chk *chunk.Chunk) (err error) {
 	}
 	e.done = true
 
-	// For every DDL, we must commit current transaction.
-	if err := e.ctx.NewTxn(); err != nil {
+	// For each DDL, we should commit the previous transaction and create a new transaction.
+	if err = e.ctx.NewTxn(); err != nil {
 		return errors.Trace(err)
 	}
 	defer func() { e.ctx.GetSessionVars().StmtCtx.IsDDLJobInQueue = false }()