|
@@ -1446,7 +1446,7 @@ func TestCollectBatchWithDuplicateTimestamps(t *testing.T) {
|
|
for i := 0; i < times; i++ {
|
|
for i := 0; i < times; i++ {
|
|
line := strconv.Itoa(i)
|
|
line := strconv.Itoa(i)
|
|
if i%2 == 0 {
|
|
if i%2 == 0 {
|
|
- timestamp.Add(1 * time.Nanosecond)
|
|
|
|
|
|
+ timestamp = timestamp.Add(1 * time.Nanosecond)
|
|
}
|
|
}
|
|
stream.Log(&logger.Message{
|
|
stream.Log(&logger.Message{
|
|
Line: []byte(line),
|
|
Line: []byte(line),
|