diff --git a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java index bd30aea5b61cc4006e6e56e7f579c0b6fb994f8d..d74478a4e75dc31e140bdf14a49a7ed4963e40cc 100644 --- a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java +++ b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/TelemetryDataDispatcher.java @@ -238,6 +238,10 @@ public class TelemetryDataDispatcher { } private static void toEndpoint(ServiceMeshMetricDataDecorator decorator, long minuteTimeBucket) { + if (decorator.getEndpointId() == Const.NONE) { + logger.warn("Received service mesh data {} with an id == 0", decorator); + return; + } ServiceMeshMetric metrics = decorator.getMetric(); Endpoint endpoint = new Endpoint(); endpoint.setTimeBucket(minuteTimeBucket);