diff --git a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java index f3ea308bd53050e0619ce4c867466e30bc82afa5..e00124f6c815e649d31a108946219fdd2559a561 100644 --- a/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java +++ b/oap-server/server-receiver-plugin/skywalking-mesh-receiver-plugin/src/main/java/org/apache/skywalking/aop/server/receiver/mesh/ServiceMeshMetricDataDecorator.java @@ -95,24 +95,15 @@ public class ServiceMeshMetricDataDecorator { } String endpoint = origin.getEndpoint(); + // Service mesh doesn't register client side endpoint. DetectPoint point = origin.getDetectPoint(); - if (DetectPoint.client.equals(point)) { - if (sourceServiceId != Const.NONE) { - endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(sourceServiceId, endpoint, - org.apache.skywalking.oap.server.core.source.DetectPoint.fromNetworkProtocolDetectPoint(point)); - } - } else { + if (DetectPoint.server.equals(point)) { if (destServiceId != Const.NONE) { endpointId = CoreRegisterLinker.getEndpointInventoryRegister().getOrCreate(destServiceId, endpoint, org.apache.skywalking.oap.server.core.source.DetectPoint.fromNetworkProtocolDetectPoint(point)); } } - if (endpointId != Const.NONE) { - } else { - isRegistered = false; - } - return isRegistered; }