ddl: roll back txn before handling ErrEntryTooLarge (pingcap#43867)

close pingcap#43725
ti-chi-bot · May 16, 2023 · f2f0190 · f2f0190
1 parent 04aef00
commit f2f0190
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/ddl/db_test.go b/ddl/db_test.go
@@ -979,6 +979,7 @@ func TestDDLJobErrorCount(t *testing.T) {
 	require.NotNil(t, historyJob)
 	require.Equal(t, int64(1), historyJob.ErrorCount)
 	require.True(t, kv.ErrEntryTooLarge.Equal(historyJob.Error))
+	tk.MustQuery("select * from ddl_error_table;").Check(testkit.Rows())
 }
 
 func TestCommitTxnWithIndexChange(t *testing.T) {

diff --git a/ddl/ddl_worker.go b/ddl/ddl_worker.go
@@ -457,6 +457,11 @@ func (w *worker) handleUpdateJobError(t *meta.Meta, job *model.Job, err error) e
 	}
 	if kv.ErrEntryTooLarge.Equal(err) {
 		logutil.Logger(w.logCtx).Warn("[ddl] update DDL job failed", zap.String("job", job.String()), zap.Error(err))
+		w.sess.Rollback()
+		err1 := w.sess.Begin()
+		if err1 != nil {
+			return errors.Trace(err1)
+		}
 		// Reduce this txn entry size.
 		job.BinlogInfo.Clean()
 		job.Error = toTError(err)