Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

disttask: refactor scheduler part #46669

Merged
merged 11 commits into from
Sep 6, 2023
Prev Previous commit
Next Next commit
fix merge
  • Loading branch information
D3Hunter committed Sep 5, 2023
commit 7938302ee87d4335b2b64ceb562e834e44924d7f
2 changes: 1 addition & 1 deletion ddl/ddl.go
Original file line number Diff line number Diff line change
Expand Up @@ -683,7 +683,7 @@ func newDDL(ctx context.Context, options ...Option) *ddl {
scheduler.RegisterTaskType(BackfillTaskType,
func(ctx context.Context, id string, taskID int64, taskTable scheduler.TaskTable, pool scheduler.Pool) scheduler.Scheduler {
return newBackfillDistScheduler(ctx, id, taskID, taskTable, pool, d)
},
}, scheduler.WithSummary,
)

backFillDsp, err := NewBackfillingDispatcherExt(d)
Expand Down