diff --git a/dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ThreadPoolExecutorInstrumentation.java b/dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ThreadPoolExecutorInstrumentation.java index e2b175d1b9..9f644d1f7e 100644 --- a/dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ThreadPoolExecutorInstrumentation.java +++ b/dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ThreadPoolExecutorInstrumentation.java @@ -55,7 +55,6 @@ public class ThreadPoolExecutorInstrumentation extends Instrumenter.Default { if (queue.size() == 0) { try { queue.add(new GenericRunnable()); - System.err.println("ADDED to queue " + queue.getClass()); queue.clear(); // Remove the Runnable we just added. } catch (final ClassCastException e) { ExecutorInstrumentation.ConcurrentUtils.disableExecutor(executor); diff --git a/dd-java-agent/instrumentation/java-concurrent/src/test/groovy/ExecutorInstrumentationTest.groovy b/dd-java-agent/instrumentation/java-concurrent/src/test/groovy/ExecutorInstrumentationTest.groovy index c77ba1eea6..ea28c8f411 100644 --- a/dd-java-agent/instrumentation/java-concurrent/src/test/groovy/ExecutorInstrumentationTest.groovy +++ b/dd-java-agent/instrumentation/java-concurrent/src/test/groovy/ExecutorInstrumentationTest.groovy @@ -13,7 +13,6 @@ import java.util.concurrent.ExecutorService import java.util.concurrent.ForkJoinPool import java.util.concurrent.Future import java.util.concurrent.RejectedExecutionException -import java.util.concurrent.ScheduledThreadPoolExecutor import java.util.concurrent.ThreadPoolExecutor import java.util.concurrent.TimeUnit @@ -67,8 +66,6 @@ class ExecutorInstrumentationTest extends AgentTestRunner { new ForkJoinPool() | executeMethod new ThreadPoolExecutor(1, 1, 1000, TimeUnit.NANOSECONDS, new ArrayBlockingQueue(1)) | submitMethod new ThreadPoolExecutor(1, 1, 1000, TimeUnit.NANOSECONDS, new ArrayBlockingQueue(1)) | executeMethod - new ScheduledThreadPoolExecutor(1) | submitMethod - new ScheduledThreadPoolExecutor(1) | executeMethod } // more useful name breaks java9 javac @@ -108,6 +105,5 @@ class ExecutorInstrumentationTest extends AgentTestRunner { poolImpl | _ new ForkJoinPool() | _ new ThreadPoolExecutor(1, 1, 1000, TimeUnit.NANOSECONDS, new ArrayBlockingQueue(1)) | _ - new ScheduledThreadPoolExecutor(1) | _ } }