We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cc22aa2 commit ec0891bCopy full SHA for ec0891b
logstash-core/src/main/java/org/logstash/execution/QueueReadClientBatchMetrics.java
@@ -43,12 +43,13 @@ public void setupMetrics(AbstractNamespacedMetricExt namespacedMetric) {
43
}
44
45
public void updateBatchMetrics(QueueBatch batch) {
46
- if (batch.events().isEmpty()) {
47
- // avoid to increment batch count for empty batches
+ if (batchMetricMode == QueueFactoryExt.BatchMetricMode.DISABLED) {
48
return;
49
50
51
- if (batchMetricMode == QueueFactoryExt.BatchMetricMode.DISABLED) {
+ if (batch.events().isEmpty()) {
+ // avoid to increment batch count for empty batches
52
+ currentBatchDimensions.set(Arrays.asList(0L, 0L));
53
54
55
0 commit comments