diff --git a/ddl/db_partition_test.go b/ddl/db_partition_test.go index 13f435e958b94..8b2ea57a4ccdb 100644 --- a/ddl/db_partition_test.go +++ b/ddl/db_partition_test.go @@ -4579,14 +4579,14 @@ func TestReorgPartitionConcurrent(t *testing.T) { injected := false hook.OnJobRunBeforeExported = func(job *model.Job) { - if /* TODO: uncomment!! job.Type == model.ActionReorganizePartition && */ job.SchemaState == model.StateWriteReorganization && !injected { + if job.Type == model.ActionReorganizePartition && job.SchemaState == model.StateWriteReorganization && !injected { injected = true <-wait <-wait } } alterErr := make(chan error, 1) - go backgroundExec(store /* TODO: uncomment!! schemaName, */, "alter table t reorganize partition p1 into (partition p1a values less than (15), partition p1b values less than (20))", alterErr) + go backgroundExec(store, schemaName, "alter table t reorganize partition p1 into (partition p1a values less than (15), partition p1b values less than (20))", alterErr) wait <- true tk.MustExec(`insert into t values (14, "14", 14),(15, "15",15)`) wait <- true