[skywalking] branch fix-mq-local-span-npe created (now 7093de61c2)

[lu...@apache.org]

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

lujiajing pushed a change to branch fix-mq-local-span-npe
in repository https://gitbox.apache.org/repos/asf/skywalking.git


      at 7093de61c2 setSourceEndpointOwnerServiceLayer

This branch includes the following new commits:

     new 7093de61c2 setSourceEndpointOwnerServiceLayer

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: setSourceEndpointOwnerServiceLayer

[lu...@apache.org]

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

lujiajing pushed a commit to branch fix-mq-local-span-npe
in repository https://gitbox.apache.org/repos/asf/skywalking.git

commit 7093de61c2d95e383d8f73e617920ccf7c24f07e
Author: Megrez Lu <lu...@gmail.com>
AuthorDate: Sun Jul 3 23:31:50 2022 +0800

    setSourceEndpointOwnerServiceLayer
---
 .../parser/listener/EndpointDepFromCrossThreadAnalysisListener.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/listener/EndpointDepFromCrossThreadAnalysisListener.java b/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/listener/EndpointDepFromCrossThreadAnalysisListener.java
index 9ae66b5e78..9f5edb5ace 100644
--- a/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/listener/EndpointDepFromCrossThreadAnalysisListener.java
+++ b/oap-server/analyzer/agent-analyzer/src/main/java/org/apache/skywalking/oap/server/analyzer/provider/trace/parser/listener/EndpointDepFromCrossThreadAnalysisListener.java
@@ -93,6 +93,7 @@ public class EndpointDepFromCrossThreadAnalysisListener extends CommonAnalysisLi
                     } else {
                         sourceBuilder.setSourceLayer(Layer.VIRTUAL_GATEWAY);
                     }
+                    sourceBuilder.setSourceEndpointOwnerServiceLayer(Layer.GENERAL);
                 } else {
                     sourceBuilder.setSourceServiceName(reference.getParentService());
                     sourceBuilder.setSourceServiceInstanceName(reference.getParentServiceInstance());