From 4ed21e1c9dca59b8a4125c9769e7519af328414a Mon Sep 17 00:00:00 2001
From: Gao Hongtao <hanahmily@gmail.com>
Date: Mon, 23 Dec 2019 11:57:58 +0800
Subject: [PATCH] Filter endpoint with an id == 0 (#4105)

---
 .../aop/server/receiver/mesh/TelemetryDataDispatcher.java     | 4 ++++
 1 file changed, 4 insertions(+)

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 bd30aea5b6..d74478a4e7 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);
-- 
GitLab