Fix test flake

jack-berg · jack-berg · commit 3fa9c51c6aa6 · 2025-02-25T09:33:27.000-06:00
diff --git a/sdk/logs/src/test/java/io/opentelemetry/sdk/logs/export/BatchLogRecordProcessorTest.java b/sdk/logs/src/test/java/io/opentelemetry/sdk/logs/export/BatchLogRecordProcessorTest.java
@@ -156,9 +156,7 @@ void maxExportBatchSizeExceedsQueueSize() throws InterruptedException {
       emitLog(sdkLoggerProvider, "log " + i);
     }
 
-    Thread.sleep(10);
-
-    verify(mockLogRecordExporter, times(1)).export(any());
+    await().untilAsserted(() -> verify(mockLogRecordExporter, times(1)).export(any()));
   }
 
   @Test
diff --git a/sdk/trace/src/test/java/io/opentelemetry/sdk/trace/export/BatchSpanProcessorTest.java b/sdk/trace/src/test/java/io/opentelemetry/sdk/trace/export/BatchSpanProcessorTest.java
@@ -164,7 +164,7 @@ void maxExportBatchSizeExceedsQueueSize() throws InterruptedException {
 
     Thread.sleep(10);
 
-    verify(mockSpanExporter, times(1)).export(any());
+    await().untilAsserted(() -> verify(mockSpanExporter, times(1)).export(any()));
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -156,9 +156,7 @@ void maxExportBatchSizeExceedsQueueSize() throws InterruptedException {`
`156`	`156`	`emitLog(sdkLoggerProvider, "log " + i);`
`157`	`157`	`}`
`158`	`158`
`159`		`- Thread.sleep(10);`
`160`		`-`
`161`		`- verify(mockLogRecordExporter, times(1)).export(any());`
	`159`	`+ await().untilAsserted(() -> verify(mockLogRecordExporter, times(1)).export(any()));`
`162`	`160`	`}`
`163`	`161`
`164`	`162`	`@Test`
Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ void maxExportBatchSizeExceedsQueueSize() throws InterruptedException {`
`164`	`164`
`165`	`165`	`Thread.sleep(10);`
`166`	`166`
`167`		`- verify(mockSpanExporter, times(1)).export(any());`
	`167`	`+ await().untilAsserted(() -> verify(mockSpanExporter, times(1)).export(any()));`
`168`	`168`	`}`
`169`	`169`
`170`	`170`	`@Test`