diff --git a/opentelemetry-sdk/src/logs/log_processor.rs b/opentelemetry-sdk/src/logs/log_processor.rs index b9f5e9094a..9f5dc3f343 100644 --- a/opentelemetry-sdk/src/logs/log_processor.rs +++ b/opentelemetry-sdk/src/logs/log_processor.rs @@ -129,7 +129,11 @@ impl LogProcessor for SimpleLogProcessor { } fn force_flush(&self) -> LogResult<()> { - Ok(()) + if let Ok(mut exporter) = self.exporter.lock() { + exporter.force_flush() + } else { + Err(LogError::MutexPoisoned("SimpleLogProcessor".into())) + } } fn shutdown(&self) -> LogResult<()> {