diff --git a/drainer/schema_test.go b/drainer/schema_test.go index 876d4e2e9..f5a070f53 100644 --- a/drainer/schema_test.go +++ b/drainer/schema_test.go @@ -56,7 +56,7 @@ func (t *schemaSuite) TestSchema(c *C) { jobs = append(jobs, job) // construct a rollbackdone job - jobs = append(jobs, &model.Job{ID: 5, State: model.JobStateRollbackDone}) + jobs = append(jobs, &model.Job{ID: 5, State: model.JobStateRollbackDone, BinlogInfo: &model.HistoryInfo{}}) // reconstruct the local schema schema, err := NewSchema(jobs, false)