diff --git a/model/adjuster/clockskew.go b/model/adjuster/clockskew.go index 26dca7cfb4e..047541aae17 100644 --- a/model/adjuster/clockskew.go +++ b/model/adjuster/clockskew.go @@ -173,7 +173,14 @@ func (a *clockSkewAdjuster) calculateSkew(child *node, parent *node) time.Durati } func (a *clockSkewAdjuster) adjustTimestamps(n *node, skew clockSkew) { + if skew.delta == 0 { + return + } + n.span.StartTime = n.span.StartTime.Add(skew.delta) + n.span.Tags = append(n.span.Tags, model.String("time.adjustment.warning", fmt.Sprintf("Warning: this span's timestamps were adjusted by %v", skew.delta))) + n.span.Tags = append(n.span.Tags, model.String("time.adjustment.url", "https://github.com/jaegertracing/jaeger/issues/961")) + for i := range n.span.Logs { n.span.Logs[i].Timestamp = n.span.Logs[i].Timestamp.Add(skew.delta) }