(skywalking) branch master updated: Remove redanduent source in mock mode (#12033)

[wusheng]

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

wusheng 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 f4836327a6 Remove redanduent source in mock mode (#12033)
f4836327a6 is described below

commit f4836327a65efe76cbbc12f013cc9cbc63a82b2c
Author: Gao Hongtao <hanahm...@gmail.com>
AuthorDate: Mon Mar 18 14:11:20 2024 +0800

    Remove redanduent source in mock mode (#12033)
---
 .../java/org/apache/skywalking/restapi/SegmentGeneratorHandler.java  | 5 -----
 1 file changed, 5 deletions(-)

diff --git 
a/oap-server/server-tools/data-generator/src/main/java/org/apache/skywalking/restapi/SegmentGeneratorHandler.java
 
b/oap-server/server-tools/data-generator/src/main/java/org/apache/skywalking/restapi/SegmentGeneratorHandler.java
index 6e7a520dbf..0b018324c3 100644
--- 
a/oap-server/server-tools/data-generator/src/main/java/org/apache/skywalking/restapi/SegmentGeneratorHandler.java
+++ 
b/oap-server/server-tools/data-generator/src/main/java/org/apache/skywalking/restapi/SegmentGeneratorHandler.java
@@ -35,8 +35,6 @@ import io.netty.util.concurrent.Future;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.skywalking.oap.server.analyzer.module.AnalyzerModule;
 import 
org.apache.skywalking.oap.server.analyzer.provider.trace.parser.ISegmentParserService;
-import org.apache.skywalking.oap.server.core.CoreModule;
-import org.apache.skywalking.oap.server.core.source.SourceReceiver;
 import org.apache.skywalking.oap.server.library.module.ModuleManager;
 
 import java.util.List;
@@ -51,13 +49,11 @@ import java.util.stream.IntStream;
 
 @Slf4j
 public class SegmentGeneratorHandler {
-    private final SourceReceiver sourceReceiver;
     private final Map<String, Future<?>> futures = new ConcurrentHashMap<>();
     private final EventLoopGroup eventLoopGroup = 
EventLoopGroups.newEventLoopGroup(10);
     private final ISegmentParserService segmentParserService;
 
     public SegmentGeneratorHandler(ModuleManager manager) {
-        sourceReceiver = 
manager.find(CoreModule.NAME).provider().getService(SourceReceiver.class);
         segmentParserService = 
manager.find(AnalyzerModule.NAME).provider().getService(ISegmentParserService.class);
     }
 
@@ -79,7 +75,6 @@ public class SegmentGeneratorHandler {
             final List<SegmentGenerator.SegmentResult> segments = 
request.next(null);
             log.debug("Generating segment: {}", (Object) segments);
             segments.forEach(s -> {
-                sourceReceiver.receive(s.segment);
                 segmentParserService.send(s.segmentObject);
             });
         };