Skip to content
This repository was archived by the owner on Aug 23, 2023. It is now read-only.

Commit c16f94f

Browse files
Rebase master
1 parent bce2ae0 commit c16f94f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cmd/mt-kafka-mdm-report-out-of-order/inputooofinder.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ func (ip *inputOOOFinder) ProcessIndexControlMsg(msg schema.ControlMsg, partitio
9999
func (ip *inputOOOFinder) incrementCounts(metricKey schema.MKey, metricTime int64, track Track, partition int32) {
100100
track.Count++
101101

102-
_, err := track.reorderBuffer.Add(uint32(metricTime), 0) // ignore value
102+
_, _, err := track.reorderBuffer.Add(uint32(metricTime), 0) // ignore value
103103
if err == errors.ErrMetricTooOld {
104104
track.OutOfOrderCount++
105105
} else if err == errors.ErrMetricNewValueForTimestamp {

0 commit comments

Comments
 (0)