Skip to content
This repository has been archived by the owner on Nov 24, 2023. It is now read-only.

Commit

Permalink
update log
Browse files Browse the repository at this point in the history
  • Loading branch information
WangXiangUSTC committed Jan 20, 2020
1 parent 99e32ce commit 70d6e8e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dm/master/coordinator/coordinator.go
Original file line number Diff line number Diff line change
Expand Up @@ -392,7 +392,7 @@ func (c *Coordinator) tryRestartMysqlTask() {
for hasTaskToSchedule {
select {
case source := <-c.waitingTask:
log.L().Info("try restart mysql task", zap.String("source", source))
log.L().Info("will schedule source", zap.String("source", source))
if cfg, ok := c.taskConfigs[source]; ok {
ret := false
if w, ok := c.upstreams[source]; ok {
Expand Down

0 comments on commit 70d6e8e

Please sign in to comment.