diff --git a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java
index 13ae6b19199e..357b884fbb18 100644
--- a/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java
+++ b/runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorkerTest.java
@@ -2970,10 +2970,6 @@ public void testActiveThreadMetric() throws Exception {
 
     ShardedKey key1Shard1 = ShardedKey.create(ByteString.copyFromUtf8("key1"), 1);
 
-    // overriding definition of MockWork to add sleep, which will help us keep track of how
-    // long each work item takes to process and therefore let us manipulate how long the time
-    // at which we're at max threads is.
-
     // real work
     MockActiveWork m1 =
         new MockActiveWork(1) {