dm-worker: fix panic in query status (pingcap#274)

lichunzhu · Sep 9, 2019 · 2c262b8 · 2c262b8
1 parent 6112114
commit 2c262b8
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dm/worker/status.go b/dm/worker/status.go
@@ -93,7 +93,7 @@ func (w *Worker) Status(stName string) []*pb.SubTaskStatus {
 			if cu != nil {
 				stStatus.Unit = cu.Type()
 				// oneof status
-				us := st.Status()
+				us := cu.Status()
 				switch stStatus.Unit {
 				case pb.UnitType_Check:
 					stStatus.Status = &pb.SubTaskStatus_Check{Check: us.(*pb.CheckStatus)}
@@ -161,7 +161,7 @@ func (w *Worker) Error(stName string) []*pb.SubTaskError {
 			}
 
 			// oneof error
-			us := st.Error()
+			us := cu.Error()
 			switch cu.Type() {
 			case pb.UnitType_Check:
 				stError.Error = &pb.SubTaskError_Check{Check: us.(*pb.CheckError)}