[skywalking] branch servicemesh-patch created (now b972f0c)

[ha...@apache.org]

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

hanahmily pushed a change to branch servicemesh-patch
in repository https://gitbox.apache.org/repos/asf/skywalking.git.


      at b972f0c  Filter endpoint with an id == 0

This branch includes the following new commits:

     new b972f0c  Filter endpoint with an id == 0

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[skywalking] 01/01: Filter endpoint with an id == 0

[ha...@apache.org]

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

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

commit b972f0c7a07876ef9818c273979669c24a8ec9bd
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Mon Dec 23 11:07:27 2019 +0800

    Filter endpoint with an id == 0
---
 .../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);