diff --git a/dd-trace-core/src/main/java/datadog/trace/core/PendingTraceBuffer.java b/dd-trace-core/src/main/java/datadog/trace/core/PendingTraceBuffer.java index 8596a6e8d95..219352bf6df 100644 --- a/dd-trace-core/src/main/java/datadog/trace/core/PendingTraceBuffer.java +++ b/dd-trace-core/src/main/java/datadog/trace/core/PendingTraceBuffer.java @@ -245,7 +245,7 @@ public void run() { if (pendingTrace instanceof FlushElement) { // Since this is an MPSC queue, the drain needs to be called on the consumer thread - queue.drain(WriteDrain.WRITE_DRAIN, 50); + queue.drain(WriteDrain.WRITE_DRAIN); flushCounter.incrementAndGet(); continue; }