Skip to content

Commit b3aadcd

Browse files
author
weixiang
committed
Fix unknown metadata in L2 aggregate worker
1 parent b81ef19 commit b3aadcd

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

docs/en/changes/changes.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,7 @@
106106
* BanyanDB: fix when setting `@BanyanDB.TimestampColumn`, the column should not be indexed.
107107
* OAP Self Observability: make Trace analysis metrics separate by label `protocol`, add Zipkin span dropped metrics.
108108
* BanyanDB: Move data write logic from BanyanDB Java Client to OAP and support observe metrics for write operations.
109+
* Fix unknown metadata in L2 aggregate worker.
109110

110111
#### UI
111112

oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/MetricsPersistentWorker.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import org.apache.skywalking.oap.server.core.analysis.TimeBucket;
3030
import org.apache.skywalking.oap.server.core.analysis.data.MergableBufferedData;
3131
import org.apache.skywalking.oap.server.core.analysis.data.ReadWriteSafeCache;
32+
import org.apache.skywalking.oap.server.core.analysis.meter.Meter;
3233
import org.apache.skywalking.oap.server.core.analysis.metrics.Metrics;
3334
import org.apache.skywalking.oap.server.core.exporter.ExportEvent;
3435
import org.apache.skywalking.oap.server.core.status.BootingStatus;
@@ -292,6 +293,9 @@ private void prepareFlushDataToStorage(List<Metrics> metricsList,
292293
}
293294

294295
private void nextWorker(Metrics metrics) {
296+
if (metrics instanceof Meter) {
297+
((Meter) metrics).initMeta(model.getName(), model.getScopeId());
298+
}
295299
nextAlarmWorker.ifPresent(nextAlarmWorker -> nextAlarmWorker.in(metrics));
296300
nextExportWorker.ifPresent(
297301
nextExportWorker -> nextExportWorker.in(new ExportEvent(metrics, ExportEvent.EventType.TOTAL)));

0 commit comments

Comments
 (0)