Skip to content

Commit

Permalink
post merge fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
mjonss committed Dec 30, 2022
1 parent 4dcfbc7 commit e0308d7
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions ddl/db_partition_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit e0308d7

Please sign in to comment.