[skywalking] branch master updated: Filter endpoint with an id == 0 (#4105)

[ha...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/skywalking.git


The following commit(s) were added to refs/heads/master by this push:
     new 4ed21e1  Filter endpoint with an id == 0 (#4105)
4ed21e1 is described below

commit 4ed21e1c9dca59b8a4125c9769e7519af328414a
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Mon Dec 23 11:57:58 2019 +0800

    Filter endpoint with an id == 0 (#4105)
---
 .../skywalking/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 bd30aea..d74478a 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);