Skip to content

Commit c5a6189

Browse files
authored
[Dataflow Streaming] Fix outstanding bundle metric reporting (#36455)
1 parent b2e1238 commit c5a6189

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ private WorkerMessage createWorkerMessageForStreamingScalingReport() {
328328
StreamingScalingReport activeThreadsReport =
329329
new StreamingScalingReport()
330330
.setActiveThreadCount(workExecutor.activeCount())
331-
.setActiveBundleCount(workExecutor.elementsOutstanding())
331+
.setOutstandingBundleCount(workExecutor.elementsOutstanding())
332332
.setOutstandingBytes(workExecutor.bytesOutstanding())
333333
.setMaximumThreadCount(workExecutor.getMaximumPoolSize())
334334
.setMaximumBundleCount(workExecutor.maximumElementsOutstanding())

0 commit comments

Comments
 (0)