diff --git a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java
index 7c5a338e7a96..374dd97a1b16 100644
--- a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java
+++ b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java
@@ -328,7 +328,7 @@ private WorkerMessage createWorkerMessageForStreamingScalingReport() {
     StreamingScalingReport activeThreadsReport =
         new StreamingScalingReport()
             .setActiveThreadCount(workExecutor.activeCount())
-            .setActiveBundleCount(workExecutor.elementsOutstanding())
+            .setOutstandingBundleCount(workExecutor.elementsOutstanding())
             .setOutstandingBytes(workExecutor.bytesOutstanding())
             .setMaximumThreadCount(workExecutor.getMaximumPoolSize())
             .setMaximumBundleCount(workExecutor.maximumElementsOutstanding())