fix: potential nil panic (#2602)
Signed-off-by: Jim Ma <majinjing3@gmail.com>
This commit is contained in:
parent
dcea13aa47
commit
a64140ff72
|
|
@ -293,7 +293,7 @@ func (ptm *peerTaskManager) prefetchParentTask(request *schedulerv1.PeerTaskRequ
|
||||||
logger.Infof("prefetch peer task %s/%s", taskID, req.PeerId)
|
logger.Infof("prefetch peer task %s/%s", taskID, req.PeerId)
|
||||||
prefetch, err := ptm.getPeerTaskConductor(context.Background(), taskID, req, limit, nil, nil, desiredLocation, false)
|
prefetch, err := ptm.getPeerTaskConductor(context.Background(), taskID, req, limit, nil, nil, desiredLocation, false)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logger.Errorf("prefetch peer task %s/%s error: %s", prefetch.taskID, prefetch.peerID, err)
|
logger.Errorf("prefetch peer task %s error: %s", taskID, err)
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -620,7 +620,7 @@ func (s *server) recursiveDownloadWithDirectMetadata(
|
||||||
parentReq := queue.PopFront()
|
parentReq := queue.PopFront()
|
||||||
request, err := source.NewRequestWithContext(ctx, parentReq.Url, parentReq.UrlMeta.Header)
|
request, err := source.NewRequestWithContext(ctx, parentReq.Url, parentReq.UrlMeta.Header)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Errorf("generate url [%v] request error: %v", request.URL, err)
|
log.Errorf("generate url [%v] request error: %v", parentReq.Url, err)
|
||||||
span.RecordError(err)
|
span.RecordError(err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue