diff --git a/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java b/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java index 1d41cd6f1..e28491a0f 100644 --- a/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java +++ b/spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanReporter.java @@ -16,8 +16,8 @@ package org.springframework.cloud.sleuth.stream; -import java.util.ArrayList; import java.util.Iterator; +import java.util.LinkedList; import java.util.List; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; @@ -53,7 +53,7 @@ public class StreamSpanReporter implements SpanReporter { @InboundChannelAdapter(value = SleuthSource.OUTPUT) public Spans poll() { - List result = new ArrayList<>(); + List result = new LinkedList<>(); this.queue.drainTo(result); for (Iterator iterator = result.iterator(); iterator.hasNext();) { Span span = iterator.next();