Update sdk/trace/batch_span_processor.go

Co-authored-by: Tyler Yahn <MrAlias@users.noreply.github.com>
open-telemetry · Oct 29, 2021 · 4eb4f2b · 4eb4f2b
1 parent c7e4c51
commit 4eb4f2b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/trace/batch_span_processor.go b/sdk/trace/batch_span_processor.go
@@ -269,7 +269,7 @@ func (bsp *batchSpanProcessor) processQueue() {
 		case sd := <-bsp.queue:
 			if ffs, ok := sd.(forceFlushSpan); ok {
 				close(ffs.flushed)
-				return
+				continue
 			}
 			bsp.batchMutex.Lock()
 			bsp.batch = append(bsp.batch, sd)