diff --git a/sdk/log/batch_test.go b/sdk/log/batch_test.go index c15e3d01446..70b12ab04fa 100644 --- a/sdk/log/batch_test.go +++ b/sdk/log/batch_test.go @@ -384,7 +384,7 @@ func TestBatchProcessor(t *testing.T) { require.NoError(t, b.OnEmit(ctx, Record{})) } assert.Eventually(t, func() bool { - return e.ExportN() > 0 + return e.ExportN() > 0 && len(b.exporter.input) == cap(b.exporter.input) }, 2*time.Second, time.Microsecond) // 1 export being performed, 1 export in buffer chan, >1 batch // still in queue that an attempt to flush will be made on.