diff --git a/sdk/trace/batch_span_processor.go b/sdk/trace/batch_span_processor.go
index aa146bcfd00..0499db15c8f 100644
--- 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)