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); }); };