(skywalking) branch data-generator created (now 92145108e6)

[ha...@apache.org]

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

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


      at 92145108e6 Remove redanduent source

This branch includes the following new commits:

     new 92145108e6 Remove redanduent source

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: Remove redanduent source

[ha...@apache.org]

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

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

commit 92145108e61083c4409ebc8c64add9948fabdd1b
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Mon Mar 18 13:17:11 2024 +0800

    Remove redanduent source
    
    Signed-off-by: Gao Hongtao <ha...@gmail.com>
---
 .../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);
             });
         };