refactor

apache · Jan 10, 2025 · 89b1cc3 · 89b1cc3
1 parent 6dba948
commit 89b1cc3
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java b/...src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
@@ -664,10 +664,9 @@ public void run()
             }
 
             // Emit the processed bytes metric
-            IndexTaskUtils.setTaskDimensions(new ServiceMetricEvent.Builder(), task);
-            toolbox.getEmitter().emit(
-                ServiceMetricEvent.builder().setMetric("ingest/processed/bytes", bytesProcessed)
-            );
+            final ServiceMetricEvent.Builder metricBuilder = new ServiceMetricEvent.Builder();
+            IndexTaskUtils.setTaskDimensions(metricBuilder, task);
+            toolbox.getEmitter().emit(metricBuilder.setMetric("ingest/processed/bytes", bytesProcessed));
 
             if (shouldProcess) {
               final List<InputRow> rows = parser.parse(record.getData(), isEndOfShard(record.getSequenceNumber()));